java 打造阻塞式线程池的实例详解
程序员文章站
2024-02-13 10:12:34
java 打造阻塞式线程池的实例详解
原来以为tiger已经自带了这种线程池,就是在任务数量超出时能够阻塞住投放任务的线程,主要想用在jms消息监听。
开始做法:...
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(); } }
多线程程序很容易出错,写好了要拼命的用压力测试,否则问题多多啊~~~
感谢阅读,希望能帮助到大家,谢谢大家对本站的支持,如有疑问请留言或者到本站社区交流讨论!