1、为什么使用线程池,线程池的优势是什么?(所有池化技术)
线程池做的工作主要是控制运行的线程的数量,处理过程中将任务放入队列,然后再线程创建之后启动这些任务,如果线程数量超过了最大数量,则超出的线程排队等待,等其他线程执行完毕,再从队列中取出任务来执行。
主要特点
-
线程服用
降低资源消耗。通过重复利用已经创建的线程,降低了线程创建和销毁的消耗。 -
控制最大并发数
提高响应速度。当任务到达时,任务可以不必等待线程创建,而立即执行 -
管理线程
提高线程的可管理性。线程是稀缺资源,不仅会消耗系统资源,还会降低系统的稳定性,使用线程池可以进行统一的分配,调优和监控。
2、线程池如何使用?
Java中的线程池是通过Executor框架实现的,该框架中用到了Executor,Executors,ExecutorService,ThreadPoolExecutor这几个类。
2.1、结构图
线程池底层就是ThreadPoolExecutor类!
2.1、编码实现
2.1.1、了解
-
Executors.newScheduledThreadPool()
带时间调度的线程池 - Java8 新增:
Executors.newWorkStealingPool(int)
使用目前机器上可用的处理器作为他的并行级别
2.1.2、重点
-
Executor.newFixedThreadPool(int)
固定线程数
适用:执行长期的任务,性能好很多 -
Executor.newSingleThreadExecutor()
单线程
适用:一个任务一个任务执行的场景 -
Executor.newCachedThreadPool()
可扩容的
适用:执行很多短期异步的小程序或者负载较轻的服务器
package com.company;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;
//第四种Java使用多线程的方式:使用线程池
public class MyThreadPoolDemo {
public static void main(String[] args) {
//一池5线程,一个银行有五个工作人员
//ExecutorService threadPool = Executors.newFixedThreadPool(5);//一池5线程
//ExecutorService threadPool = Executors.newSingleThreadExecutor();//一池1线程
ExecutorService threadPool = Executors.newCachedThreadPool();//一池N线程,自动适配线程个数
//模拟十个用户,每一个用户对应一个外部请求
try
{
for (int i = 1; i <= 10 ; i++) {
threadPool.execute(()->{
System.out.println(Thread.currentThread().getName()+"\t办理业务");
});
//try{TimeUnit.MILLISECONDS.sleep(5);}catch (InterruptedException e){e.printStackTrace();}
}
}catch(Exception e){
e.printStackTrace();
}finally{
threadPool.shutdown();
}
}
}
Console:
pool-1-thread-1 办理业务
pool-1-thread-5 办理业务
pool-1-thread-4 办理业务
pool-1-thread-2 办理业务
pool-1-thread-3 办理业务
pool-1-thread-7 办理业务
pool-1-thread-6 办理业务
pool-1-thread-8 办理业务
pool-1-thread-9 办理业务
pool-1-thread-5 办理业务
2.3、ThreadPoolExecutor
2.3.1、Executor.newFixedThreadPool(int)
的源码实现
2.3.2、Executor.newSingleThreadExecutor()
的源码实现
2.3.3、Executor.newCachedThreadPool()
的源码实现
线程池两个要素:
- ThreadPoolExecutor类
- 阻塞队列,同步队列