這期內(nèi)容當(dāng)中小編將會(huì)給大家?guī)?lái)有關(guān)如何正確的使用JDK線程池和Spring線程池，文章內(nèi)容豐富且以專業(yè)的角度為大家分析和敘述，閱讀完這篇文章希望大家可以有所收獲。
JDK線程池和Spring線程池實(shí)例，異步調(diào)用，可以直接使用
(1)JDK線程池的使用，此處采用單例的方式提供，見(jiàn)示例：
重慶分公司
重慶分公司
public class ThreadPoolUtil {
private static int corePoolSize = 5;
private static int maximumPoolSize = 10;
private static long keepAliveTime = 60L;
private static TimeUnit unit = TimeUnit.SECONDS;
private static int capacity = 1024;
private static ThreadFactory namedThreadFactory = new ThreadFactoryBuilder().setNameFormat("jdk-thread-pool-%d").build();
private static final ExecutorService executorService = new ThreadPoolExecutor(corePoolSize,
maximumPoolSize,
keepAliveTime,
unit,
new LinkedBlockingQueue<>(capacity),
namedThreadFactory,
new ThreadPoolExecutor.AbortPolicy());
private ThreadPoolUtil () {
}
public static ExecutorService getExecutorService () {
return executorService;
}
}在其它地方可以直接這樣使用：
ThreadPoolUtil.getExecutorService().execute(() -> {
System.out.println("test1");
System.out.println("test2");
}
)(2)Spring線程池的使用，此處通過(guò)配置類(lèi)的方式配置線程池的相關(guān)屬性，見(jiàn)示例：
@Configuration
@EnableAsync
public class DocataThreadBeanConfig {
private int corePoolSize = 5;
private int maxPoolSize = 10;
private int queueCapacity = 1024;
private String namePrefix = "async-service-task-";
// 上述屬性可以通過(guò)@Value來(lái)讀取配置值
@Bean(name = "asyncServiceTaskExecutor")
public TaskExecutor asyncServiceExecutor() {
ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
// 設(shè)置核心線程數(shù)
executor.setCorePoolSize(corePoolSize);
// 設(shè)置大線程數(shù)
executor.setMaxPoolSize(maxPoolSize);
// 設(shè)置隊(duì)列容量
executor.setQueueCapacity(queueCapacity);
// 設(shè)置線程活躍時(shí)間（秒）
executor.setKeepAliveSeconds(60);
// 設(shè)置默認(rèn)線程名稱
executor.setThreadNamePrefix(namePrefix);
// 設(shè)置拒絕策略
executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
// 等待所有任務(wù)結(jié)束后再關(guān)閉線程池
executor.setWaitForTasksToCompleteOnShutdown(true);
executor.initialize();
;
return executor;
}
}在其它文件中需要這樣使用：
@Resource(name="asyncServiceTaskExecutor") private ThreadPoolTaskExecutor asyncServiceTaskExecutor;
不要直接使用@Autowired，否則會(huì)提示失敗的
@Autowired private ThreadPoolTaskExecutor asyncServiceTaskExecutor;
上述就是小編為大家分享的如何正確的使用JDK線程池和Spring線程池了，如果剛好有類(lèi)似的疑惑，不妨參照上述分析進(jìn)行理解。如果想知道更多相關(guān)知識(shí)，歡迎關(guān)注創(chuàng)新互聯(lián)網(wǎng)站建設(shè)公司行業(yè)資訊頻道。
另外有需要云服務(wù)器可以了解下創(chuàng)新互聯(lián)建站www.cdcxhl.com，海內(nèi)外云服務(wù)器15元起步，三天無(wú)理由+7*72小時(shí)售后在線，公司持有idc許可證，提供“云服務(wù)器、裸金屬服務(wù)器、高防服務(wù)器、香港服務(wù)器、美國(guó)服務(wù)器、虛擬主機(jī)、免備案服務(wù)器”等云主機(jī)租用服務(wù)以及企業(yè)上云的綜合解決方案，具有“安全穩(wěn)定、簡(jiǎn)單易用、服務(wù)可用性高、性價(jià)比高”等特點(diǎn)與優(yōu)勢(shì)，專為企業(yè)上云打造定制，能夠滿足用戶豐富、多元化的應(yīng)用場(chǎng)景需求。
