品易云推流 关闭
文章详情页
文章 > java基础 > java中关闭ExecutorService

java中关闭ExecutorService

java ExecutorService关闭

头像

小妮浅浅

2021-01-11 17:58:453071浏览 · 0收藏 · 0评论

ExecutorService除了可以对线程池进行管理外,优势在于它可以进行关闭。不过要借用其中的一些关闭方法:shutdown()和shutdownNow(),和ExecutorService结合一起作用于线程池。下面就关闭线程池的方法进行分析,然后展示关闭方法的使用,最后结合ExecutorService关闭实例分享给大家。

1.关闭线程池

可以调用shutdown()或shutdownNow()来关闭线程池,其中原理是遍历所有工作线程,然后逐个调用线程的interrupt()来进行中断。但是它们存在一定的区别,shutdownNow首先将线程池的状态设置成STOP,然后尝试停止所有的正在执行或暂停任务的线程,并返回等待执行任务的列表,而shutdown只是将线程池的状态设置成SHUTDOWN状态,然后中断所有没有正在执行任务的线程。

2.关闭方法

shutdown(): Executor创建时处于运行状态。当调用ExecutorService.shutdown()后,线程池就会关闭,拒绝新提交的任务, 终止前允许执行以前提交的任务,包括队列中的任务。

shutdownNow():会将线程池关闭,拒绝新提交的任务,对于正在运行的线程进行打断,阻塞的队列中任务也会打断。这里会返回所有没有开始的任务。

isShutdown():是否关闭

isTerminated():是否所有的任务已经完成,如果完成则返回true

3.实例

如果程序通过 main() 方法启动,并且主线程退出了你的程序,如果还有活动的 ExecutorService 存在于程序中,存在于 ExecutorService 中的活动线程会阻止Java虚拟机关闭。

ExecutorService executorService = Executors.newCachedThreadPool();
 
//开启异步线程
executorService.execute(new SendRestult(processService, jsonString, approvalFlag, lesseeId));
 
 
public final class SendRestult implements Runnable {
 
    private IProcessService processService;
    private String params;
    private Integer approvalFlag;
    private String lesseeId;
 
    public SendRestult(IProcessService processService, String jsonData, Integer approvalFlag, String lesseeId) {
        this.processService = processService;
        this.params = jsonData;
        this.approvalFlag = approvalFlag;
        this.lesseeId = lesseeId;
    }
 
    @Override
    public void run() {
        try {
            //调用第三方接口
            processService.invokeSendStatusData(params, approvalFlag, lesseeId);
        } catch (Exception e) {
            logger.error("异步推送出现了问题:", e);
        }
    }
}

以上就是java中关闭ExecutorService的方法,相信在关闭线程池的同时,也学会了shutdown等方法的使用。学会后就赶快动手尝试下吧。

关注

关注公众号,随时随地在线学习

本教程部分素材来源于网络,版权问题联系站长!

底部广告图