Java。遇到一个问题。需要停止一个运行时的模块T
模块T里又分了子模块ABCDE
每个子模块都有自己的线程池
T是一个被调用的角色。
然后我可以确定的是每个子模块的线程池的submit肯定是要去调用
另一个模块J的(这点非常重要)
T被触发后。ABCDE之间会有数据轮转。当然还有锁的使用
现在外部调用方判断T需要停止。然后重置。再重新调用。
我一开始以为很简单啊。把变量设置成null。然后重新new不就完了么。
然后用jstack 发现线程还在。数据也还在。。。而且这些线程感觉就要很久之后才会被回收了（因为要等run方法全部执行完。然后系统gc。。）。因为我用的是线程池。
然后我又去了解了一下shutdown。shutdownNow和isTerminated 3个方法
结合我自己的代码。我说一下我的方法把
因为我的锁是我自己用atomicBoolean封装的一个单独的类。
所以我可以控制是不是真的要用到锁，如果用lock的可能就还需要处理lock。
我ABCDE这些子模块都有父类。创建线程池的方法是在父类里的。
我用的一般就是newFixedThreadPool和newSingleThreadExecutor。这2个
所以我就自定义了一个类重写了这2个方法。再自定义了一个类（AThreadPoolExecutor）继承自ThreadPoolExecutor.重写了submit和execute这2个方法。
@Override
public Futuresubmit(Runnable task) {
try{
return super.submit(task);
}catch (RejectedExecutionException executionException){
}
return null;
}
@Override
public Futuresubmit(Runnable task, T result) {
try{
return super.submit(task, result);
}catch (RejectedExecutionException executionException){
}
return null;
}
@Override
public Futuresubmit(Callable task) {
try{
return super.submit(task);
}catch (RejectedExecutionException executionException){
}
return null;
}
@Override
public void execute(Runnable command) {
try {
super.execute(command);
}catch (Exception e){
if (einstanceof InterruptedException){
}else {
throw e;
}
}
}
类似这样。这样就保证我在停止的时候碰到提交和中断就不会出问题。（因为外面submit的地方实在太多了。。改不过来）
然后呢。我直接去调用每个线程池的shutdownNow。把所有未执行的任务都去除。
然后因为每个submit的内容都是要去调用J的。照着模块之间调用你起码要封装一层的做法
所以我在判断我要停止的时候。直接在调用J的那个地方去判断了线程的状态
if (Thread.currentThread().isInterrupted()){
throw new InterruptedException(Thread.currentThread().getName());
}
return super.run(log,o,method,objects,methodProxy);
就像这样。这就能保证我所有的submit都能被很快的处理完（这当然是因为的submit里没有啥while啊for啊这种耗时循环这种）
然后剩下的就简单了。
把线程池重开就完事。
重开的时候判断下isTerminated
如果是false。。我现在的做法就是先打个警告log。发现再来排查问题。
网友评论