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();
 }
 }

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

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