java 打造阻塞式线程池的实例详解
java打造阻塞式线程池的实例详解
原来以为tiger已经自带了这种线程池，就是在任务数量超出时能够阻塞住投放任务的线程，主要想用在JMS消息监听。
开始做法：
在ThreadPoolExcecutor中代入newArrayBlockingQueue(MAX_TASK).在任务超出时报错：RejectedExecutionException。
后来不用execute方法加入任务，直接getQueue().add(task),利用其阻塞特性。但是发现阻塞好用了，但是任务没有被处理。一看Queue,晕啊，原来都在里面，任务池就没处理它。看样还是要走任务池。
最后自己重载了一个BlockedThreadPoolExecutor:
privateReentrantLockpauseLock=newReentrantLock();
privateConditionunpaused=pauseLock.newCondition();
@Override
publicvoidexecute(Runnablecommand){
pauseLock.lock();
try{
while(getPoolSize()==getMaximumPoolSize()&&getQueue().remainingCapacity()==0)
unpaused.await();
super.execute(command);//放到lock外面的话，在压力测试下会有漏网的！
}catch(InterruptedExceptione){
log.warn(this,e);
}finally{
pauseLock.unlock();
}
}
@Override
protectedvoidafterExecute(Runnabler,Throwablet){
super.afterExecute(r,t);
try{
pauseLock.lock();
unpaused.signal();
}finally{
pauseLock.unlock();
}
}
多线程程序很容易出错，写好了要拼命的用压力测试，否则问题多多啊~~~
感谢阅读，希望能帮助到大家，谢谢大家对本站的支持，如有疑问请留言或者到本站社区交流讨论！