Executor和scheduleWithFixedDelay()

Question

这是我的任务。我有一个类中的静态作业队列和一个将作业添加到队列中的静态方法。有n个线程从队列中轮询并执行拉出的作业。我需要在一个间隔内同时进行n个线程轮询。也就是说，所有三个人都应该每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

从文件中：

如果此任务的任何执行时间超过其周期，则随后的执行可能会延迟启动，但不会同时执行。

因此，您必须安排三个独立的任务，以便它们同时运行。还请注意，调度的executor服务是一个固定的线程池，对于许多用例来说不够灵活。一个很好的成语是使用预定的服务将任务提交给常规的executor服务，该服务可以配置为一个可调整大小的线程池。

Answer 2

您正在以固定的延迟运行ScheduledExecutorService，这意味着您的作业将一个接一个地运行。使用固定线程池，每次提交3个线程。这是举例说明

Answer 3

如果您声明了Job extends Runnable，那么您的代码就会大大简化：

首先，在全局可访问的某个位置声明执行者：

public static final ExecutorService executor = Executors.newFixedThreadPool(MAX_THREADS);

然后添加一个这样的工作：

executor.submit(new Job());

你完了。