控制ExecutorService最多每秒执行N个任务

本文介绍了控制ExecutorService最多每秒执行N个任务的处理方法，对大家解决问题具有一定的参考价值，需要的朋友们下面随着小编来一起学习吧！ 问题描述

如何控制/限制提交到 ExecutorService ？我有 SMSTask 发送短信，我需要控制执行器，以便它最多只能发送N条消息/秒。

How to control/limit the tasks that are submitted to a ExecutorService? I have SMSTask that sends SMS messages and I need to control the executor so that it can only send at maximum N messages/second.

推荐答案

假设您正在为每个任务创建一条短信，您可以使用ScheduleExecutorService。

Assuming you are creating one SMS message per task you can use a ScheduleExecutorService.

final Queue<Task> tasks = new ConcurrentLinkedQueue<Task>(); int ratePerSecond = 10; final ExecutorService es = Executors.newCachedThreadPool(); ScheduledExecutorService ses = Executors.newSingleThreadScheduledExecutor(); ses.scheduleAtFixedRate(new Runnable() { @Override public void run() { final Task task = tasks.poll(); if (task == null) return; es.submit(new Runnable() { @Override public void run() { process(task); } }); } }, 0, 1000/ratePerSecond, TimeUnit.MILLISECONDS);

将任务添加到队列中，它们将以每秒10个的速度进行处理。

Add tasks to the queue and they will be processed at a rate of 10 per second.