Java并发：如何选择和配置执行器

Question

Java 并发 API 为您提供了 Executor 和 ExecutorService 接口以供您构建，并附带几个具体实现（ThreadPoolExecutor 和 ScheduledThreadPoolExecutor）。

我对 Java 并发完全陌生，并且很难找到几个非常相似的问题的答案。我决定将它们捆绑在一起，而不是把所有这些小问题弄得一团糟，因为可能有一种方法可以一口气回答它们（可能是因为我在这里没有看到全貌）：

• 实现自己的Executor/ExecutorService是常见的做法吗？在什么情况下你会这样做而不是使用我上面提到的两个结核？在什么情况下，这两种结核比“本土”的东西更可取？
• 我不明白所有并发集合与Executors 的关系。例如，ThreadPoolExecutor 是否在后台使用 ConcurrentLinkedQueue 来对提交的任务进行排队？还是您（API 开发人员）应该在并行化的run() 方法中选择和使用ConcurrentLinkedQueue？基本上，那里的并发集合是供Executors 内部使用的，还是您使用它们来帮助编写非阻塞算法？
• 您能否配置 Executor 在后台使用哪些并发集合（存储提交的任务），这是常见的做法吗？

提前致谢！

Answer 1

实现自己的 Executor/ExecutorService 是常见的做法吗？

没有。我从来没有这样做过，而且我使用并发包已经有一段时间了。这些类的复杂性以及“错误”对性能的影响意味着您应该真的在进行这样的项目之前仔细考虑一下。

我觉得需要实现自己的执行器服务的唯一一次是当我想实现一个“自运行”的执行器服务时。直到一个朋友告诉我有一个way to do it with a RejectedExecutionHandler。

我想要调整 ThreadPoolExecutor 行为的唯一原因是让它启动所有线程直到最大线程数，然后然后将作业放入队列中.默认情况下，ThreadPoolExecutor 启动 min-threads，然后在启动另一个线程之前填充队列。不是我期望或想要的。但是我只是从 JDK 中复制代码并对其进行更改——而不是从头开始实现它。

我不明白所有并发集合与 Executor 的关系。例如，ThreadPoolExecutor 是否在后台使用 ConcurrentLinkedQueue 对提交的任务进行排队？

如果您使用的是Executors 辅助方法之一，那么您不必担心这一点。如果您自己实例化 ThreadPoolExecutor，那么您需要提供 BlockingQueue 以供使用。

public static ExecutorService newFixedThreadPool(int nThreads) {
    return new ThreadPoolExecutor(nThreads, nThreads,
           0L, TimeUnit.MILLISECONDS, new LinkedBlockingQueue<Runnable>());
}

对比：

 ExecutorService threadPool = 
     new ThreadPoolExecutor(minThreads, maxThreads, 0L, TimeUnit.MILLISECONDS,
            new SynchronousQueue<Runnable>());

您能否配置 Executor 在后台使用哪些并发集合（用于存储提交的任务），这是常见的做法吗？

查看最后一个答案。