线程池:三大方法、7大参数、4种拒绝策略
程序员文章站
2022-09-13 22:19:17
池化技术:程序运行就是资源的占用,池化就是优化资源利用,线程池,连接池啥的,创建销毁很耗费时间空间,所以就提前准备好资源,你来那就行,用完换回来。减少资源消耗,速度提升,还有或就是方便管理,线程复用,就像sqlsession一样,查出数据存着,可控制最大并发三大方法:(不建议使用)//三大方法public class ThreeMathed { public static void main(String[] args) { ExecutorService pool= E...
池化技术:
程序运行就是资源的占用,池化就是优化资源利用,线程池,连接池啥的,创建销毁很耗费时间空间,所以就提前准备好资源,你来那就行,用完换回来。
减少资源消耗,速度提升,还有或就是方便管理,线程复用,就像sqlsession一样,查出数据存着,可控制最大并发
三大方法:(不建议使用)
//三大方法
public class ThreeMathed {
public static void main(String[] args) {
ExecutorService pool= Executors.newSingleThreadExecutor();//单个线程
// ExecutorService pool= Executors.newFixedThreadPool(5);//自己设置固定的
// ExecutorService pool= Executors.newCachedThreadPool();//可伸缩,遇强则强
try {
for (int i = 0; i < 100; i++) {
//使用线程池后,创建线程
pool.execute(()->{
System.out.println(Thread.currentThread().getName()+"--Ok");
});
}
} catch (Exception e) {
e.printStackTrace();
} finally {
//关闭线程池
pool.shutdown();
}
}
}
7大参数
/**
* 四大拒绝策略
* 1.new ThreadPoolExecutor.AbortPolicy()//银行满了,还有人来,直接报错java.util.concurrent.RejectedExecutionException
* 2.new ThreadPoolExecutor.CallerRunsPolicy()//队列满了,哪来的回哪去(main)
* 3.new ThreadPoolExecutor.DiscardPolicy()//队列加最大容量满了,直接丢掉任务,不会抛出异常
* 4.new ThreadPoolExecutor.DiscardOldestPolicy()//队列加最大容量满了,尝试和最早的竞争,不会抛出异常
*/
public class SevenParams {
public static void main(String[] args) {
//自定义线程池,七大参数
ExecutorService threadPool =new ThreadPoolExecutor(
2,//核心容量
5,//最大容量
3,//阻塞时间
TimeUnit.SECONDS,//时间单位
new LinkedBlockingDeque<>(3),//阻塞队列,就是银行等候区
Executors.defaultThreadFactory(),
new ThreadPoolExecutor.CallerRunsPolicy()//队列满了,哪来的回哪去(main)
);
try {
//最大承载=核心容量+阻塞队列
//超过
for (int i = 0; i < 9; i++) {
threadPool.execute(()->{
System.out.println(Thread.currentThread().getName()+"ok");
});
}
} catch (Exception e) {
e.printStackTrace();
} finally {
//记得关闭线程池
threadPool.shutdown();
}
}
}
4种拒绝策略,就是最大承载=核心容量+阻塞队列,满了的策略
/**
- new ThreadPoolExecutor.AbortPolicy() // 银行满了,还有人进来,不处理这个人的,抛出异常
- new ThreadPoolExecutor.CallerRunsPolicy() // 哪来的去哪里!
- new ThreadPoolExecutor.DiscardPolicy() //队列满了,丢掉任务,不会抛出异常!
- new ThreadPoolExecutor.DiscardOldestPolicy() //队列满了,尝试去和最早的竞争,也不会抛出异常!
*/
本文地址:https://blog.csdn.net/code_mzh/article/details/107143975