XXLJOB终止定时任务的犯二小故事

Posted 2020-11-28 windghost

xxljob中终止定时任务的方式是通过Thread.interrupt()+处理中断异常的方式强制终止任务的。所以单纯的线程只要进行阻塞操作就可以实现终止。

但是代码里已经遍布了ThreadPoolExecutor创建出来的线程池，尝试各种方式线程内部都不能感受到外部线程的interrupt，尝试了多次无果。

 

今天忽然想明白了，在外部线程中等待线程池执行完成的地方，处理线程的终止异常，抛出异常给xxljob进行捕获同时，调用线程池的shutdownNow()方法即可。

由于shutdownNow()的实现方式实际还是Thread.interrupt()，所以只要线程内部在合适的地方加上Thread.sleep(x)即可。