线程池的创建方式:
1、newCachedThreadPoo:
创建一个可缓存的线程池,当线程池的线程数量超过任务数量时,自动回收空闲线程,当线程当任务数量超过线程池的线程数量时,自动添加新线程;
ExecutorService executor = Executors,newCachedThreadPool();
for (int i = 0;i < 10; i++) {
//模拟10个任务
executor.submit(new Runnable() {
@Override
public void run() {
// 线程执行的代码
}
});
executor.shutdown () ;
2、newFixedThreadPool(int n)
创建一个固定大小的线程池,线程数量固定为n,当任务数量超过线程池的线程数量时,任务会被放在任务队列中等待执行。
ExecutorService executor = Executors.newFixedThreadPool(5);
for (int i = 0; i< 10; i++) {
//模拟10个任务
executor.submit (new Runnable () {
@Override
public void run() {
// 线程执行的代码
}
});
}
executor.shutdown () ;
3、newSingleThreadExecutorl :
创建一个单线程的线程池,所有任务都在同一个线程中,顺序执行。
ExecutorService executor = Executors.newSingleThreadExecutor();
for (int i = 0;< 10; i++) {
//模拟10个任务
executor.submit (new Runnable(){
@Override
public void run() {
// 线程执行的代码
}
});
}
executor.shutdown ();
4、newScheduledThreadPool(int corePoolSize)
ScheduledExecutorService executor =Executors.newScheduledThreadPoo1(2);
for (int i = 0;i < 10; i++) {
//模拟10个任务
executor.schedule(new Runnable () {
@Override
public void run{
// 线程执行代码
}
},5,TimeUnit.SECONDS);
}
executor.shutdown () ;
建一个定时任务的线程池,可以在指定的时间间隔内周期性的执行任务,在阿里巴巴这么开发手册中,建议开发者手动创建线程。
[强制]线程池不允许使用 Executors 去创建,而是通过ThreadPoolExecutor的方式,这4样的处理方式让写的同学更加明确线程池的运行规则,规避资源耗尽的风险。
说明: Executors 返回的线程池对象的弊端如下
1)FixedThreadPool和 SinaleThreadPool :
允许的请求队列长度为 Integer.MAX_VALUE,可能会堆积大量的请求,从而导致 OOM
2)CachedThreadPool :
允许的创建线程数量为 Integer.MAX_VALUE,可能会创建大量的线程,从而导致 OOM。
这是因为Executors工具类虽然提供了一些便利的方法来创建线程池,这些方法并没有很好的考虑到线程池的使用场景和实际需求,容易导致线程池的滥用。进而引发各种问题;
我们可以通过ThreadPoolExecutor手动创建:
自定义设置参数:
corePoolSize :线程池的核心线程数,即在没有任务需要执行时线程池的大小
maximumPoolSize:线程池最大能够容纳的线程数,当线程池的工作队列已满并且仍有新的任务到来时,线程池就会创建新的线程,直到达到该参数指定的上限;
keepAliveTime: 当线程池中线程数量超过核心线程数时,这时多余的空闲线程在终止之前等待新任务的最长时间
unit,keepAliveTime:参数的时间单位
workQueue:任务队列,用于存放等待执行的任务
threadFactory:线程工厂,用于创建新线程的工厂
handler:拒绝策略,当线程池无法处理新任务时的处理方式
ExecutorService threadPool = new ThreadPoolExecutor(
2,// 核心线程数
10,// 最大线程数
2L,//空闲线程存活时间
TimeUnit.SECONDS,// 空闲线程活跃时间单位
new LinkedBlockingQueue<Runnable>(5),// 线程池任务队列
Executors.defaultThreadFactory()// 默认线程工厂
new ThreadPoolExecutor.AbortPolicy() // 拒绝策略
);
try {
for (int i = 0;< 10; i++) { // 模拟10个用户来办理业务
threadPool.execute(() ->{
// 线程要执行的任务;
});
}
} catch (Exception e) {
e.printstackTrace() ;
} finally {
threadPool.shutdown(); // 关闭线程池
}