java 打造阻塞式线程池的实例详解
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(); } }
多线程程序很容易出错,写好了要拼命的用压力测试,否则问题多多啊~~~
感谢阅读,希望能帮助到大家,谢谢大家对本站的支持,如有疑问请留言或者到本站社区交流讨论!
相关文章
Java8 使用 stream().sorted()对List集合进行排序的操作
这篇文章主要介绍了Java8 使用 stream().sorted()对List集合进行排序的操作,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧2020-10-10java web学习_浅谈request对象中get和post的差异
下面小编就为大家带来一篇java web学习_浅谈request对象中get和post的差异。小编觉得挺不错的,现在就分享给大家,也给大家做个参考。一起跟随小编过来看看吧2017-05-05feign post参数对象不加@RequestBody的使用说明
这篇文章主要介绍了feign post参数对象不加@RequestBody的使用说明,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教2021-10-10SpringBoot整合Redis及Redis工具类撰写实例
这篇文章主要介绍了SpringBoot整合Redis及Redis工具类撰写实例,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教2022-01-01
最新评论