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 countDownLatch如何实现多线程任务阻塞等待 # Java使用阻塞队列控制线程通信的方法实例详解 # Java多线程阻塞与唤醒代码示例 # 详解Java多线程编程中CountDownLatch阻塞线程的方法 # 详解Java多线程编程中LockSupport类的线程阻塞用法 # 聊聊Java中是什么方法导致的线程阻塞 # 压力测试 # 会有 # 好了 # 都在 # 如有 # 很容易 # 就没 # 希望能 # 要走 # 带了 # 谢谢大家 # 想用 # 多线程 # 疑问请 # 就是在 # 好用了 # getQueue # add # RejectedExecutionException # execute

返回目录在线咨询

上一篇：python中包初始化有什么好处？
下一篇：建站主机选购指南与服务器配置方案解析

您的项目需求

*请认真填写需求信息，我们会在24小时内与您取得联系。

全网整合营销服务商

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

您的项目需求