java打造阻塞式线程池的实例详解-创新互联

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

成都创新互联-专业网站定制、快速模板网站建设、高性价比额济纳网站开发、企业建站全套包干低至880元,成熟完善的模板库,直接使用。一站式额济纳网站制作公司更省心,省钱,快速模板网站建设找我们，业务覆盖额济纳地区。费用合理售后完善，十多年实体公司更值得信赖。

原来以为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打造阻塞式线程池的实例详解-创新互联
文章转载：https://www.cdcxhl.com/article30/peipo.html

成都网站建设公司_创新互联，为您提供面包屑导航、外贸网站建设、网站导航、外贸建站、品牌网站建设、品牌网站制作

广告

声明：本网站发布的内容（图片、视频和文字）以用户投稿、用户转载内容为主，如果涉及侵权请尽快告知，我们将会在第一时间删除。文章观点不代表本网站立场，如需处理请联系客服。电话：028-86922220；邮箱：631063699@qq.com。内容未经允许不得转载，或转载时需注明来源： 创新互联