线程池的原理正在学习中,如有不当之处,请勿见怪,这篇文章仅仅是我怕忘记而写的。
1.线程池出现的原因
当需要使用很多个线程时,如果还是采用简单的创建线程的方式,会导致系统开销变大。
因为在创建线程和关闭线程中会占用系统开销。如果一个线程在执行完一个任务继续执行下一个任务,那么效率将大大提高。
2.线程池正是解决了上面的问题,只要定义好任务,然后交给线程池,你不需要知道它是如何执行的、被哪个线程执行的、什么时候执行的。
3.具体的实现原理大家可以参照海子的博客:http://www.cnblogs.com/dolphin0520/p/3932921.html
4.简单的线程池实例和分析
public class ExecutorCase {
private static Executor executor = Executors.newFixedThreadPool(5);
public static void main(String[] args) {
for (int i = 0; i <10 ; i++) {
System.out.println("第"+i+"次执行");
executor.execute(new Task());
executor.execute(new Task1());
}
}
static class Task1 implements Runnable{
@Override
public void run() {
System.out.println(Thread.currentThread().getName()+"---");
}
}
static class Task implements Runnable{
public void run(){
System.out.println(Thread.currentThread().getName());
}
}
}
执行结果
第0次执行
pool-1-thread-1
第1次执行
第2次执行
pool-1-thread-2---
pool-1-thread-3
pool-1-thread-4---
第3次执行
pool-1-thread-1---
pool-1-thread-2---
pool-1-thread-3
第4次执行
pool-1-thread-5
pool-1-thread-1---
pool-1-thread-4
第5次执行
第6次执行
pool-1-thread-3---
第7次执行
pool-1-thread-5
pool-1-thread-2
pool-1-thread-3---
pool-1-thread-4
第8次执行
pool-1-thread-1---
pool-1-thread-2---
pool-1-thread-5
第9次执行
pool-1-thread-3
pool-1-thread-4---
5.结果分析
可以看到线程的执行是没有顺序的,当executor.execute(new Task())执行完成后就会创建一个线程,并执行start()方法,让线程处于就绪状态,至于什么时候它能执行,这是由cpu调度决定的。
这里设置了corePoolSize为5,线程池的数量大于5后,新进来的任务将进入阻塞队列中,等待线程池中的某个线程空闲下来后,再从阻塞队列中获取。
- 如果当前线程池中的线程数目小于corePoolSize,则每来一个任务,就会创建一个线程去执行这个任务;
- 如果当前线程池中的线程数目>=corePoolSize,则每来一个任务,会尝试将其添加到任务缓存队列当中,若添加成功,则该任务会等待空闲线程将其取出去执行;若添加失败(一般来说是任务缓存队列已满),则会尝试创建新的线程去执行这个任务;
- 如果当前线程池中的线程数目达到maximumPoolSize,则会采取任务拒绝策略进行处理;
- 如果线程池中的线程数量大于 corePoolSize时,如果某线程空闲时间超过keepAliveTime,线程将被终止,直至线程池中的线程数目不大于corePoolSize;如果允许为核心池中的线程设置存活时间,那么核心池中的线程空闲时间超过keepAliveTime,线程也会被终止。
网友评论