Java：ExecutorService 比手动线程执行效率低？

Question

我有一个多线程应用程序。当使用 Thread.start() 手动启动线程时，每个并发线程恰好使用 25% 的 CPU（或恰好一个核心 - 这是在四核机器上）。所以如果我运行两个线程，CPU 使用率正好是 50%。

然而，当使用 ExecutorService 运行线程时，似乎有一个“幽灵”线程消耗 CPU 资源！一个线程使用 50% 而不是 25%，两个线程使用 75%，等等。

这可能是某种 Windows 任务管理器人工制品吗？

执行器服务代码是

ExecutorService executor = Executors.newFixedThreadPool(threadAmount);

for (int i = 1; i < 50; i++) {
    Runnable worker = new ActualThread(i);
    executor.execute(worker);
}
executor.shutdown();
while (!executor.isTerminated()) {

}
System.out.println("Finished all threads");

而 Thread.start() 代码是：

ActualThread one= new ActualThread(2,3);
ActualThread two= new ActualThread(3,4);
...

Thread threadOne = new Thread(one);
Thread threadTtwo = new Thread(two);
...

threadOne.start();
threadTwo.start();
...

Answer 1

这是你的问题：

while (!executor.isTerminated()) {

}

您的“主要”方法使 CPU 无所事事。改用invokeAll()，你的线程会在没有忙等待的情况下阻塞。

final ExecutorService executor = Executors.newFixedThreadPool(threadAmount);
final List<Callable<Object>> tasks = new ArrayList<Callable<Object>>();

for (int i = 1; i < 50; i++) {
    tasks.add(Executors.callable(new ActualThread(i)));
}
executor.invokeAll(tasks);
executor.shutdown();  // not really necessary if the executor goes out of scope.
System.out.println("Finished all threads");

由于invokeAll() 想要Callable 的集合，请注意使用辅助方法Executors.callable()。实际上，您也可以使用它来获取任务的 Futures 集合，如果任务实际上产生了您想要的输出，这将非常有用。