java 打造阻塞式線程池的實例詳解
java 打造阻塞式線程池的實例詳解
原來以為tiger已經自帶了這種線程池,就是在任務數(shù)量超出時能夠阻塞住投放任務的線程,主要想用在JMS消息監(jiān)聽。
開始做法:
在ThreadPoolExcecutor中代入new ArrayBlockingQueue(MAX_TASK). 在任務超出時報錯:RejectedExecutionException。
后來不用execute方法加入任務,直接getQueue().add(task), 利用其阻塞特性。但是發(fā)現(xiàn)阻塞好用了,但是任務沒有被處理。一看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(); } }
多線程程序很容易出錯,寫好了要拼命的用壓力測試,否則問題多多啊~~~
感謝閱讀,希望能幫助到大家,謝謝大家對本站的支持,如有疑問請留言或者到本站社區(qū)交流討論!
相關文章
在SSM框架中將圖片上傳到數(shù)據(jù)庫中的實現(xiàn)代碼
這篇文章主要介紹了在SSM框架中將圖片上傳到數(shù)據(jù)庫中的實現(xiàn)代碼,本文通過實例代碼給大家介紹的非常詳細,對大家的學習或工作具有一定的參考借鑒價值,需要的朋友可以參考下2021-03-03Javaweb-HttpServletResponse的sendRedirectch重定向方式
這篇文章主要介紹了Javaweb-HttpServletResponse的sendRedirectch重定向方式,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教2023-09-09Spring?Boot如何配置yml配置文件定義集合、數(shù)組和Map
這篇文章主要介紹了Spring?Boot?優(yōu)雅配置yml配置文件定義集合、數(shù)組和Map,包括Spring?Boot?yml配置文件定義基本數(shù)據(jù)類型和引用數(shù)據(jù)類型的方式,需要的朋友可以參考下2023-10-10Struts2學習筆記(6)-簡單的數(shù)據(jù)校驗
這篇文章主要介紹Struts2中的數(shù)據(jù)校驗,通過一個簡單的例子來說明,希望能給大家做一個參考。2016-06-06