Java|Java 线程池模型的思考和选择(已更新)
多谢 风水 同学提出的问题。我重新研究了下源代码,纠正下我之前存在的错误的理论。于是对之前的文章做了修正,之前对大家引起的误导表示非常道歉。
这里对之前的文章重新进行了下梳理和研究,希望大家斧正。
---- 正文 -----
这几天总是讨论线程创建方式的问题,说性能比那个最优,哪个更方便等等。对于熟悉java的人来说,最先接触的应该是ExecutorService,这种线程池管理的方式操作比较简单,也广受大家好评。但是在很多系统上还有其他的实现方式,把Thread对象new出来,放进容器里面。这些Thread不停的取Queue(有生产者会往里面放待处理数据)里的数据进行处理,不停进行循环。可以到queue没数据的时候进行阻塞,直到有数据重新开始。
但是这里要说明一点的是,这两者的原理是一样的,只不过ExecutorService会借助Runnable来实现初始化线程,直到初始化满为止,后续的Runnable执行使用。具体的源码分析在后续的文章中一起分析。
不过对于自己的实现,和ExecutorService的实现,虽然一样,但是还是想看两者的速度如何。于是我做了一个小实验,来简单判断这两者的区别
ExecutorService的方式:
public static void ExecutorServiceTest() {
ExecutorService es = Executors.newFixedThreadPool(100);
for(int i = 0;
i<100;
i++) {// 进行初始化各个线程,所以现用Runnable进行补充
es.execute(new Runnable() {
int i = 9;
@Override
public void run() {
int b =i*9;
Math.acos(b);
Math.sin(b);
Math.acos(b);
Math.sin(b);
Math.acos(b);
Math.sin(b);
Math.acos(b);
Math.sin(b);
}
});
}
long time= System.currentTimeMillis();
int count = 10000000;
while(count>0) {
es.execute(new Runnable() {int i = 9;
@Override
public void run() {
int b =i*9;
Math.acos(b);
Math.sin(b);
Math.acos(b);
Math.sin(b);
Math.acos(b);
Math.sin(b);
Math.acos(b);
Math.sin(b);
}
});
count--;
}
es.shutdown();
System.out.println(System.currentTimeMillis() - time);
}
自定义线程池的方式:
public static void SelfThreadTest() {
final ConcurrentLinkedQueue queue1 = new ConcurrentLinkedQueue<>();
final List threadlist = new ArrayList<>(100);
for(int i = 0;
i<100;
i++) {
Thread t = new Thread(new Runnable() {Integer b ;
boolean next = true;
@Override
public void run() {
while(true) {
b = queue1.poll();
if(b == null) {
if(!next) {return;
}
continue;
}
int c = b*9;
Math.acos(b);
Math.sin(b);
Math.acos(b);
Math.sin(b);
Math.acos(b);
Math.sin(b);
Math.acos(b);
Math.sin(b);
next = false;
}}
});
threadlist.add(t);
}for(int i = 0;
i<100;
i++) {
threadlist.get(i).start();
}int count = 10000000;
long time= System.currentTimeMillis();
while(count>0) {
queue1.offer(count);
count --;
}while(true) {
if(threadlist.get(99).getState() == Thread.State.TERMINATED) {// 这里没有做太详细的判断略
break;
}
}System.out.println(System.currentTimeMillis() - time);
}
这两个某次运行结果为:
begin
5302
4347
end
第一行为ExecutorService的运行结果,第二行为自定义线程池的运行结果。每次的运行时间都会有所差别,但是结果都是类似的。
是的,时间还是有挺大差别的,但是这个差别并不是上次说的" 后续会重复创建线程消耗的时间” 。因为后续是不继续生成线程的,ExecutorService中的一个线程其实在内部也是不停的循环,等待Runnable过来。而这个Runnable也仅是个接口实现了run方法,Thread循环取这个run方法进行运行。而这里的时间差别应该是ExecutorService中的各种线程检查和判断损失的时间(仅猜测-我们后续文章一起分析源码)。至于选择,大家还是先择系统的比较好,毕竟可以保证结果的稳定。自定义的方式,大家可以研究研究,如果要用在生产环境上,务必需要进行足够量的测试。
【Java|Java 线程池模型的思考和选择(已更新)】如果对Java线程创建流程感兴趣,可以参考这篇文章:https://yq.aliyun.com/articles/72803 。文章中讲到Java的线程创建最终会通过JNI调用到系统的pthread_create(C语言线程创建),可见Java的线程就是真实的线程。
推荐阅读
- JAVA(抽象类与接口的区别&重载与重写&内存泄漏)
- 事件代理
- Java|Java OpenCV图像处理之SIFT角点检测详解
- java中如何实现重建二叉树
- Linux下面如何查看tomcat已经使用多少线程
- 数组常用方法一
- 【Hadoop踩雷】Mac下安装Hadoop3以及Java版本问题
- Java|Java基础——数组
- 多线程NSOperation
- RxJava|RxJava 在Android项目中的使用(一)