溫馨提示×
您好，登錄后才能下訂單哦！
點擊 登錄注冊 即表示同意《億速云用戶服務條款》
您好，登錄后才能下訂單哦！
java 打造阻塞式線程池的實例詳解
原來以為tiger已經自帶了這種線程池，就是在任務數量超出時能夠阻塞住投放任務的線程，主要想用在JMS消息監聽。
開始做法：
在ThreadPoolExcecutor中代入new ArrayBlockingQueue(MAX_TASK). 在任務超出時報錯：RejectedExecutionException。
后來不用execute方法加入任務，直接getQueue().add(task), 利用其阻塞特性。但是發現阻塞好用了，但是任務沒有被處理。一看Queue,暈啊，原來都在里面，任務池就沒處理它。看樣還是要走任務池。
最后自己重載了一個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外面的話，在壓力測試下會有漏網的！
} 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();
}
}
多線程程序很容易出錯，寫好了要拼命的用壓力測試，否則問題多多啊~~~
感謝閱讀，希望能幫助到大家，謝謝大家對本站的支持，如有疑問請留言或者到本站社區交流討論！
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
