線程和線程池
[TOC]
1.new Thread的弊端
- 每次new Thread新建對象舌胶，性能差
- 線程缺乏統(tǒng)一管理，可能無限制的新建線程疮丛，相互競爭幔嫂，有可能占用過多系統(tǒng)資源導(dǎo)致死機或者OOM
- 缺少更多功能，如更多執(zhí)行誊薄、定期執(zhí)行履恩、線程中斷
2.線程池的好處
- 重用存在的線程，減少對象創(chuàng)建呢蔫、消亡的的開銷切心，性能佳
- 可有效控制最大并發(fā)線程數(shù)，提高系統(tǒng)資源利用率咐刨，同時可以避免過多資源競爭昙衅，避免阻塞
- 提供定時執(zhí)行、定期執(zhí)行定鸟、單線程、并發(fā)控制等功能
3.線程池相關(guān)名稱解釋
- coreThreadSize：核心線程數(shù)量
- maximumPoolSize：最大線程數(shù)
- workQueue：阻塞隊列著瓶，存儲等待執(zhí)行的任務(wù)（很重要联予，會對線程池運行過程產(chǎn)生重大影響）
- keepAliveTime：線程沒有任務(wù)執(zhí)行時最多保持多久時間終止
- unit：keepAliveTime的時間單位
- threadFactory：線程工廠，用于創(chuàng)建線程
- rejectHandler：當(dāng)拒絕處理任務(wù)的策略
4.線程和線程方法
1.png
shutdown()方法：不接受新的任務(wù)，處理完隊列中的任務(wù)
stop()方法：則是直接中斷正在處理任務(wù)的線程
2.png
3.png
5.合理配置線程池
5.1 cpu密集型任務(wù)
考慮：N * CPU + 1個
5.2 io密集型任務(wù)
考慮：2 * N * CPU個
6.線程池配置使用例子
6.1 配置類 ThreadPoolConfig.class
@Configuration
public class ThreadPoolConfig {
@Data
private static class ThreadPool {
private String threadPoolName = "mall-admin-thread-pool";
private Integer coreThreadSize = Runtime.getRuntime().availableProcessors() * 2;
private Integer maxThreadSize = Runtime.getRuntime().availableProcessors() * 2;
private Long keepAliveTime = 0L;
private Integer capacity = 100;
}
private static ThreadFactory factory = null;
@Bean
public ExecutorService createThreadPool() {
ThreadPool threadPool = new ThreadPool();
factory = setFactory(threadPool.getThreadPoolName());
return new ThreadPoolExecutor(
threadPool.getCoreThreadSize(),
threadPool.getMaxThreadSize(),
threadPool.getKeepAliveTime(),
TimeUnit.MILLISECONDS,
new LinkedBlockingQueue<>(1000),
factory,
new MyAbortPolicy());
}
/**
* 設(shè)置線程池的名稱
* @param poolName
* @return
*/
private static ThreadFactory setFactory(String poolName) {
if (factory == null) {
factory = new ThreadPoolExecutorFactoryBean();
((ThreadPoolExecutorFactoryBean) factory).setBeanName(poolName);
}
return factory;
}
/**
* 自定義AbortPolicy類(即自定義飽和策略的異常處理)
*/
private static class MyAbortPolicy implements RejectedExecutionHandler {
MyAbortPolicy() {
}
@Override
public void rejectedExecution(Runnable r, ThreadPoolExecutor executor) {
throw new RejectedExecutionException(
"【線程默認飽和策略】:" + r.toString() + "線程被" + executor.toString() + "線程執(zhí)行器拒絕");
}
}
}
6.2 使用
@Autowired
private ExecutorService executorService;
...
public void excute(){
// 異步
executorService.execute(() -> doSomething());
}
