使用Executors創(chuàng)建
import java.util.concurrent.Executors;
import java.util.concurrent.ExecutorService;
ExecutorService executorService = Executors.newCachedThreadPool();
executorService.execute(
//要運行的線程
);
不足
容易資源耗盡
- newFixedThreadPool和newSingleThreadExecutor:
主要問題是堆積的請求處理隊列可能會耗費非常大的內(nèi)存隧膏，甚至OOM捏膨。
- newCachedThreadPool和newScheduledThreadPool:
主要問題是線程數(shù)最大數(shù)是Integer.MAX_VALUE择份，可能會創(chuàng)建數(shù)量非常多的線程叶雹，甚至OOM憾儒。
推薦方案1：手動創(chuàng)建得运，指定線程池大小
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.ScheduledThreadPoolExecutor;
import org.apache.commons.lang3.concurrent.BasicThreadFactory;
ScheduledExecutorService executorService = new ScheduledThreadPoolExecutor(1,
new BasicThreadFactory.Builder().namingPattern("example-schedule-pool-%d").daemon(true).build());
executorService.execute(()->{
System.out.println("testScheduledExecutorService:"+System.currentTimeMillis());
});
其中
ScheduledExecutorService extends ExecutorService
ScheduledThreadPoolExecutor(int corePoolSize, ThreadFactory threadFactory)
推薦方案2：使用spring創(chuàng)建
//配置
<bean id="cmqExecutor" class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor">
<!-- 線程池維護線程的最少數(shù)量 -->
<property name="corePoolSize" value="5" />
<!-- 允許的空閑時間 -->
<property name="keepAliveSeconds" value="200" />
<!-- 線程池維護線程的最大數(shù)量 -->
<property name="maxPoolSize" value="200" />
<!-- 緩存隊列 -->
<property name="queueCapacity" value="1000" />
<!-- 對拒絕task的處理策略 -->
<property name="rejectedExecutionHandler">
<bean class="java.util.concurrent.ThreadPoolExecutor$CallerRunsPolicy" />
</property>
</bean>
//調(diào)用
@Autowired
private ThreadPoolTaskExecutor cmqExecutor;
cmqExecutor.execute(
()->{
//TODO
}
);
線程執(zhí)行優(yōu)先級
核心線程corePoolSize>任務(wù)隊列workQueue>最大線程 maximumPoolSize>如果三者都滿則使用handler處理被拒絕的任務(wù)吓妆。
如果此時線程池中的數(shù)量小于corePoolSize俱济，即使線程池中的線程都處于空閑狀態(tài)，也要創(chuàng)建新的線程來處理被添加的任務(wù)债蜜。
如果此時線程池中的數(shù)量等于 corePoolSize晴埂，但是緩沖隊列 workQueue未滿究反，那么任務(wù)被放入緩沖隊列。
如果此時線程池中的數(shù)量大于等于corePoolSize儒洛，緩沖隊列workQueue滿精耐，并且線程池中的數(shù)量小于maxPoolSize，建新的線程來處理被添加的任務(wù)琅锻。
如果此時線程池中的數(shù)量大于corePoolSize卦停，緩沖隊列workQueue滿，并且線程池中的數(shù)量等于maxPoolSize恼蓬，那么通過handler所指定的策略來處理此任務(wù)惊完。
當(dāng)線程池中的線程數(shù)量大于corePoolSize時，如果某線程空閑時間超過keepAliveTime滚秩，線程將被終止专执。這樣，線程池可以動態(tài)的調(diào)整池中的線程數(shù)郁油。
