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

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);//放到lochttp://k外面的话，在压力测试下会有漏网的！

} catch (InterruptedException e) {

lInTTVYOpBog.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();

}

}

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

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

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。