FixedThreadPool 执行器受某些终止条件限制

Question

也许，一个新手问题，但它困扰着我，在一堆简单的教程和文档下，我没有找到答案。

问题。 在 Java 中，使用 JDK(1.8) 中的高级并行模式来实现下一个的最佳方式是什么？ N 个线程的固定池正在执行相同的预定义任务，直到达到终止条件。因此，任务的数量不是预先定义的，条件是外部实时触发。我们必须急切地对终止做出反应，但不要消耗太多资源来切换上下文并从工作线程中窃取 CPU 时间。假设我们只有两到四个弱物理线程可以在控制线程上花费很多。

如果它有帮助，当前的想法将在下一个代码中实现，但是动态任务队列，而大部分是睡眠控制周期看起来对我来说不够整洁。

try {
    mainCycle(agent, executor, terminationCondition);
} catch (InterruptedException e) {
    log.warn(INTERRUPTED_EX, e);
} finally {
    executor.shutdownNow();
}

 private static void mainCycle(Callable<Long> agent,
                                  ExecutorService executor,
                                  Supplier<Boolean> terminationCondition
) throws InterruptedException {

    final List<Future<Long>> runFutureResults = executor.
            invokeAll(Collections.nCopies(parallelAgents, agent));

    int tasksReserve = BASE_MULTIPLIER;
    //noinspection MethodCallInLoopCondition, by design
    while (!terminationCondition.get()) {
        tasksReserve = addTasksIfNeed(executor, runFutureResults);
        Thread.sleep(1000);
    }
}

Answer 1

要么使用某种协调机制（phaser，当您需要即时添加更多作业时，它在 Java 7 中引入很有用），或者只保留您在完成时设置的外部标志：

ExecutorService service = Executors.newFixedThreadPool(N);
volatile boolean done = false;

// add your jobs:
service.submit(() -> {
    while (!done) {
        // do something
    }
});

// set your flag
done = true;

flag 是 volatile 就足够了，因为只有一个线程在 mutating 值；执行器内部的线程只需要在它发生变化时可见。