java - 执行器服务和scheduleWithFixedDelay()

Question

这是我的任务。我在一个类中有一个静态作业队列，还有一个将作业添加到队列中的静态方法。有 n 个线程从队列中轮询并执行拉取的作业。我需要让 n 个线程以一定间隔同时轮询。也就是说，所有 3 个应该每 5 秒轮询一次并寻找工作。

我有这个:

public class Handler {

    private static final Queue<Job> queue = new LinkedList<>();

    public static void initialize(int maxThreads) { // maxThreads == 3

        ScheduledExecutorService executorService =
            Executors.newScheduledThreadPool(maxThreads);

        executorService.scheduleWithFixedDelay(new Runnable() {
            @Override
            public void run() {
                Job job = null;
                synchronized(queue) {
                    if(queue.size() > 0) {
                        job = queue.poll();
                    }
                }
                if(job != null) {
                    Log.log("start job");
                    doJob(job);
                    Log.log("end job");
                }
            }    
        }, 15, 5, TimeUnit.SECONDS);

    }

}

当我添加 4 个任务时，我得到这个输出:

startjob
endjob
startjob
endjob
startjob
endjob
startjob
endjob

很明显，这些线程串行执行这些作业，而我需要它们一次完成 3 个。我究竟做错了什么？谢谢!

Answer 1

来自文档:

If any execution of this task takes longer than its period, then subsequent executions may start late, but will not concurrently execute.

因此，您必须安排三个独立的任务以使它们同时运行。另请注意，调度执行器服务是一个固定的线程池，对于许多用例来说不够灵活。一个好的习惯用法是使用计划服务将任务提交到常规执行程序服务，该服务可以配置为可调整大小的线程池。