java 打造阻塞式線程池的實(shí)例詳解
更新時(shí)間：2017年07月30日 10:14:13 作者：steeven
這篇文章主要介紹了java 打造阻塞式線程池的實(shí)例詳解的相關(guān)資料,這里提供實(shí)例幫助大家，理解這部分知識(shí)，需要的朋友可以參考下
java 打造阻塞式線程池的實(shí)例詳解
原來以為tiger已經(jīng)自帶了這種線程池，就是在任務(wù)數(shù)量超出時(shí)能夠阻塞住投放任務(wù)的線程，主要想用在JMS消息監(jiān)聽。
開始做法：
在ThreadPoolExcecutor中代入new ArrayBlockingQueue(MAX_TASK). 在任務(wù)超出時(shí)報(bào)錯(cuò)：RejectedExecutionException。
后來不用execute方法加入任務(wù)，直接getQueue().add(task), 利用其阻塞特性。但是發(fā)現(xiàn)阻塞好用了，但是任務(wù)沒有被處理。一看Queue,暈啊，原來都在里面，任務(wù)池就沒處理它?？礃舆€是要走任務(wù)池。
最后自己重載了一個(gè)BlockedThreadPoolExecutor:
private ReentrantLock pauseLock = new ReentrantLock();
private Condition unpaused = pauseLock.newCondition();
@Override
public void execute(Runnable command) {
pauseLock.lock();
try {
while (getPoolSize()==getMaximumPoolSize() && getQueue().remainingCapacity()==0)
unpaused.await();
super.execute(command);//放到lock外面的話，在壓力測(cè)試下會(huì)有漏網(wǎng)的！
} catch (InterruptedException e) {
log.warn(this, e);
} finally {
pauseLock.unlock();
}
}
@Override
protected void afterExecute(Runnable r, Throwable t) {
super.afterExecute(r,t);
try{
pauseLock.lock();
unpaused.signal();
}finally{
pauseLock.unlock();
}
}
多線程程序很容易出錯(cuò)，寫好了要拼命的用壓力測(cè)試，否則問題多多啊~~~
感謝閱讀，希望能幫助到大家，謝謝大家對(duì)本站的支持，如有疑問請(qǐng)留言或者到本站社區(qū)交流討論！
相關(guān)文章
打包的方式有打包成jar包或者打包成war包發(fā)布，區(qū)別在于jar包內(nèi)置了tomcat、netty等服務(wù)器，更改只需要修改pom.xml的坐標(biāo)即可，war不內(nèi)置服務(wù)器，需要上傳到服務(wù)器tomcat解壓后運(yùn)行，本文分析Springboot打包成jar發(fā)布，感興趣的朋友一起看看吧2023-02-02
Bean標(biāo)簽一般用于配置對(duì)象交由Spring?來創(chuàng)建，這篇文章主要來和大家詳細(xì)聊聊Spring中bean標(biāo)簽的用法，感興趣的小伙伴可以跟隨小編一起學(xué)習(xí)一下2023-06-06
這篇文章主要介紹了java 中匿名內(nèi)部類的實(shí)例詳解的相關(guān)資料,這里提供實(shí)例來幫助大家學(xué)習(xí)理解這部分內(nèi)容，需要的朋友可以參考下2017-09-09
Spring實(shí)戰(zhàn)之緩存使用key操作示例
這篇文章主要介紹了Spring實(shí)戰(zhàn)之緩存使用key操作,結(jié)合實(shí)例形式分析了Spring緩存使用key具體配置、屬性、領(lǐng)域模型等相關(guān)操作技巧,需要的朋友可以參考下2020-01-01
這篇文章主要為大家詳細(xì)介紹了java網(wǎng)上圖書商城，訂單模塊第三篇，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2016-12-12
這篇文章主要介紹了Java中Servlet3.0異步處理的原理以及遇到的問題分析，需要的朋友參考一下。2017-12-12
java基礎(chǔ)詳解之?dāng)?shù)據(jù)類型知識(shí)點(diǎn)總結(jié)
這篇文章主要介紹了java基礎(chǔ)詳解之?dāng)?shù)據(jù)類型知識(shí)點(diǎn)總結(jié),文中有非常詳細(xì)的代碼示例,對(duì)正在學(xué)習(xí)java基礎(chǔ)的小伙伴們有很大的幫助,需要的朋友可以參考下2021-04-04
MyBatis是一個(gè)持久層框架,它提供了一種將數(shù)據(jù)庫操作與Java對(duì)象之間的映射關(guān)系進(jìn)行配置的方式,在MyBatis中,Mapper是用于定義數(shù)據(jù)庫操作的接口,而參數(shù)傳遞則是通過Mapper接口的方法來實(shí)現(xiàn)的,本文給大家介紹了MyBatis在mapper中傳遞參數(shù)的四種方式,需要的朋友可以參考下2024-03-03
Springcloud Config支持本地配置文件的方法示例
這篇文章主要介紹了Springcloud Config支持本地配置文件的方法示例，文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2020-02-02
帶你了解Java數(shù)據(jù)結(jié)構(gòu)和算法之高級(jí)排序
這篇文章主要為大家介紹了Java數(shù)據(jù)結(jié)構(gòu)和算法之高級(jí)排序，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下，希望能夠給你帶來幫助2022-01-01