如何正确使用Java Executor？

Question

我在我的多线程应用程序中使用了Java Executors，但我似乎不知道什么时候使用以下每一种方式是最好的：

ExecutorService executor=Executors.newFixedThreadPool(50);
executor.execute(new A_Runner(... some parameter ...));
executor.shutdown();
while (!executor.isTerminated()) { Thread.sleep(100); }

int Page_Count=200;
ExecutorService executor=Executors.newFixedThreadPool(50);
doneSignal=new CountDownLatch(Page_Count);
for (int i=0;i<Page_Count;i++) executor.execute(new A_Runner(doneSignal, ... some parameter ...));
doneSignal.await();
executor.shutdown();
while (!executor.isTerminated()) { Thread.sleep(100); }

int Executor_Count=30;
ThreadPoolExecutor executor=new ThreadPoolExecutor(Executor_Count,Executor_Count*2,1,TimeUnit.SECONDS,new LinkedBlockingQueue());
List<Future<String>> futures=new ArrayList<>(3330);

for (int i=0;i<50;i++) futures.add(executor.submit(new A_Runner(... some parameter ...));
executor.shutdown();
while (!executor.isTerminated()) { executor.awaitTermination(1,TimeUnit.SECONDS); }
for (Future<String> future : futures)
{
    String f=future.get();
    // ...
}

我想知道的是：这些方法是可以互换的，还是在某种情况下我应该使用上面的特定类型？

Answer 1

>

ExecutorService

ExecutorService Executor=Executors.NewFixedThreadPool（50）；

它简单易用。它隐藏ThreadPoolExecutor的低级详细信息。

用例：

>

实现最大并行度：有时我们希望同时启动多个线程以实现最大并行度

在开始执行之前等待N个线程完成

在ThreadPoolExecutor.DiscardoldestPolicy中，如果未关闭执行器，将删除位于工作队列头部的任务，然后重试执行（可能再次失败，导致重复执行）

如果要模拟CountDownLatch行为，可以使用InvokeAll()方法。

您没有引用的另一个机制是ForkJoinPool

  public static ExecutorService newWorkStealingPool()

默认情况下，它将以CPU核心数作为参数。

这四种机制是相辅相成的。根据您想要控制的粒度级别，您必须选择正确的粒度级别。