java打造阻塞式线程池的实例详解

首页 > 软件编程 > java 更新日期: 2017-09-10
这篇文章主要介绍了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();
 }
 }

多线程程序很容易出错,写好了要拼命的用压力测试,否则问题多多啊~~~

感谢阅读,希望能帮助到大家,谢谢大家对本站的支持,如有疑问请留言或者到本站社区交流讨论!


> 本站内容系网友提交或本网编辑转载,其目的在于传递更多信息,并不代表本网赞同其观点和对其真实性负责。如涉及作品内容、版权和其它问题,请及时与本网联系,我们将在第一时间删除内容!

相关文章
  • Java中的接口和抽象类用法实例详解
    这篇文章主要介绍了Java中的接口和抽象类用法,结合实例形式较为详细的分析了Java中关于接口和抽象类的概念.定义.用法与相关注意事项,需要的朋友可以参考下本文实例讲述了Java中的接口和抽象类用法.分享给大家供大家参考,具体如下: 在面向对象的概念中,我们知道所有的对象都是通过类来描绘的,但是并不是所有的类都是用来描绘对象的,如果一个类中没有包含足够的信息 ...
  • 简单介绍Java编程中的线程池
    这篇文章主要介绍了Java编程中的线程池,进程和线程的并发是Java编程中的重要环节,需要的朋友可以参考下从 Java 5 开始,Java 提供了自己的线程池.线程池就是一个线程的容器,每次只执行额定数量的线程. java.util.concurrent.ThreadPoolExecutor 就是这样的线程池.它很灵活,但使用起来也比较复杂,本文就对其做一个 ...
  • AnyChat的视频会议程序实例详解
    AnyChat的视频会议程序实例详解
    AnyChat是一款跨平台的音视频解决方案.通过本篇文章给大家介绍AnyChat的视频会议程序,涉及到anychat相关知识,对anychat视频会议相关知识感兴趣的朋友一起学习吧AnyChat(全名叫Anychat SDK),也叫音视频互动开发平台:是一套跨平台的即时通讯解决方案,基于先进的H.264视频编码标准.AAC音频编码标准与P2P技术,整合了佰锐 ...
  • 实例详解Android文件存储数据方式
    实例详解Android文件存储数据方式
    总体的来讲,数据存储方式有三种:一个是文件,一个是数据库,另一个则是网络.下面通过本文给大家介绍Android文件存储数据方式,对android文件存储数据相关知识感兴趣的朋友一起学习吧总体的来讲,数据存储方式有三种:一个是文件,一个是数据库,另一个则是网络.下面通过本文给大家介绍Android文件存储数据方式. 1.文件存储数据使用了Java中的IO操作来 ...
  • AndroidWebView线性进度条实例详解
    AndroidWebView线性进度条实例详解
    这篇文章主要介绍了Android WebView线性进度条实例详解的相关资料,需要的朋友可以参考下推荐阅读:Android Webview添加网页加载进度条实例详解 先给大家展示下效果图:这个效果图大家一看就懂,在生活经常见到 1.wevbview_progressbar.xml <layer-list xmlns:andro > <!-- ...
  • 实例详解Android获取短信会话列表
    本文通过实例详解android获取短信会话列表的全部内容,涉及到android获取短信列表的相关知识,对android会话列表相关知识感兴趣的朋友一起学习吧Android中的短信并没有正式的content provider可用,在官方文档中没有提供定义.不过依然可以自己定义好URI,然后查询出短信内容.例如conetent://sms则是所有短信所在的pat ...
猜你喜欢