ScheduledExecutorService 多线程并行

Question

我有兴趣使用 ScheduledExecutorService 为任务生成多个线程（如果之前的任务尚未完成）。例如我需要每0.5秒处理一个文件。第一个任务开始处理文件，0.5 秒后，如果第一个线程未完成，则生成第二个线程并开始处理第二个文件，依此类推。这可以通过以下方式完成：

    ScheduledExecutorService executor = Executors.newScheduledThreadPool(4)
    while (!executor.isShutdown()) {  
        executor.execute(task);
        try {
            Thread.sleep(500);
        } catch (InterruptedException e) {
            // handle
        }
    }

现在我的问题：为什么我不能使用 executor.scheduleAtFixedRate 来做到这一点？

我得到的是，如果第一个任务需要更长的时间，则第二个任务在第一个任务完成后立即启动，但即使执行器有线程池，也不会启动新线程。 executor.scheduleWithFixedDelay 很清楚 - 它以相同的时间跨度执行任务，并且完成任务需要多长时间并不重要。所以可能我误解了 ScheduledExecutorService 的目的。

也许我应该看看另一种执行者？或者只是使用我在这里发布的代码？有什么想法吗？

Answer 1

我通过在每个计划执行中启动一个嵌套的匿名可运行程序解决了这个问题：

final ScheduledExecutorService service = Executors.newScheduledThreadPool(POOL_SIZE);

final Runnable command = new SlowRunnable();

service.scheduleAtFixedRate(
    new Runnable() {
      @Override
      public void run() {
        service.execute(command);
      }
    }, 0, 1, TimeUnit.SECONDS);

在这个示例中，将有 1 个线程在每个时间间隔执行快速指令，因此当下一个时间间隔到期时，它肯定会完成。剩余的 POOL_SIZE-1 线程将并行执行 SlowRunnable 的 run()，这可能需要比单个间隔的持续时间更长的时间。

请注意，虽然我喜欢这个解决方案，因为它最大限度地减少了代码并重用相同的 ScheduledExecutorService，但它的大小必须正确，并且可能无法在每个上下文中使用：如果 SlowRunnable 太慢以至于最多 POOL_SIZE 作业一起执行，那么将会有没有线程能够及时运行计划任务。

另外，如果将间隔设置为 1 TimeUnit.NANOSECONDS，则主可运行对象的执行也可能会变得太慢。

Answer 2

scheduleAtFixedRate 方法就是您要查找的 为了。它会按照给定的时间间隔从池中的线程中启动一个任务，即使之前的任务尚未完成。如果您没有足够的线程来执行处理，请按照 ThreadPoolExecutor 文档。