如何实现ExecutorService以基于轮换的方式执行任务？

Question

我使用带有固定线程池的java.util.concurrent.ExecutorService执行任务列表。我的任务列表通常约为80-150，并且我将随时运行的线程数限制为10，如下所示：

ExecutorService threadPoolService = Executors.newFixedThreadPool(10);

for ( Runnable task : myTasks ) 
{     
    threadPoolService.submit(task); 
}

我的用例要求即使完成的任务也应重新提交给 ExecutorService， 但只有在服务/完成所有 已
提交的任务后才应再次执行/采用。基本上，提交的任务应以轮换为基础执行。因此，在这种情况下不会有threadPoolService.shutdown()或threadPoolService.shutdownNow()呼叫。

我的问题是，如何实现 ExecutorService 服务旋转基础任务？

Answer 1

ThreadPoolExecutor为afterExecution提供了一个扩展点，您可以在其中将作业放回队列的末尾。

public class TaskRepeatingThreadPoolExecutor extends ThreadPoolExecutor {

    public TaskRepeatingThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue) {
        super(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue);
    }

    @Override
    protected void afterExecute(Runnable r, Throwable t) {
        super.afterExecute(r, t);
        this.submit(r);
    }
}

当然，您将需要做更多的工作来自己实例化它，而无需ExecutorService使用方便的工厂方法，但是构造函数非常简单，可以轻松完成。