Java:ExecutorService比手动线程执行效率低吗?

我有一个多线程的应用程序.当使用Thread.start()手动启动线程时,每个并发线程使用恰好25%的cpu(或者恰好一个核心 – 这是在四核机器上).因此,如果我运行两个线程,cpu使用率恰好是50%.

然而,当使用ExecutorService运行线程时,似乎有一个“鬼”线程消耗cpu资源! One Thread使用50%而不是25%,两个线程使用75%等.

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

Excutor服务代码

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();
...

解决方法

这是你的问题:
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集合,如果任务实际上生成您想要的输出,这将非常有用.

相关文章

ArrayList简介:ArrayList 的底层是数组队列,相当于动态数组。与 Java 中的数组相比,它的容量能动态增...
一、进程与线程 进程:是代码在数据集合上的一次运行活动,是系统进行资源分配和调度的基本单位。 线程...
本文为博客园作者所写:&#160;一寸HUI,个人博客地址:https://www.cnblogs.com/zsql/ 简单的一个类...
#############java面向对象详解#############1、面向对象基本概念2、类与对象3、类和对象的定义格式4、...
一、什么是异常? 异常就是有异于常态,和正常情况不一样,有错误出错。在java中,阻止当前方法或作用域...
Collection接口 Collection接口 Collection接口 Collection是最基本的集合接口,一个Collection代表一组...