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打造阻塞式线程池的实例详解-创新互联
分享网址：http://hbruida.cn/article/peipo.html