线程池是否需要关闭

发表于 | 分类于 |
字数统计: 624 | 阅读时长 ≈ 2

大家在日常开发中会经常用多线程，为了合理地管理线程，我们会通过线程池来创建线程。那么在使用完线程池之后我们需要显式关闭线程池么？

举个栗子

下面我们来通过一个demo看看显式关闭线程池是否有必要

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
public class TestShutDown {
 
    private static void asynExecuteOne() {
        ExecutorService executor = Executors.newSingleThreadExecutor();
        executor.execute(() -> System.out.println("打开电脑"));
    }
 
    private static void asynExecuteTwo() {
        ExecutorService executor = Executors.newSingleThreadExecutor();
        executor.execute(() -> System.out.println("关闭电脑"));
    }
 
 
    public static void main(String[] args) throws InterruptedException {
        //(1)同步执行
        System.out.println("上班打卡");
        //(2)异步执行操作one
        asynExecuteOne();
        //(3)异步执行操作two
        asynExecuteTwo();
        //(4)执行完毕
        Thread.sleep(1000L);
        System.out.println("下班打卡");
    }
}

运行结果如下

img

上图可以看到异步任务执行完成之后主线程没有退出，如果我们在asynExecuteOne和asynExecuteTwo中任务执行完之后调d用shutdown()

1
2
3
4
5
6
private static void asynExecuteOne() {
    ExecutorService executor = Executors.newSingleThreadExecutor();
    executor.execute(() -> System.out.println("打开电脑"));
    executor.shutdown();
    //asynExecuteTwo同理
}

可以很明显的看到Process finished with exit code 0。

结论

在代码中声明临时线程池一定要shutdown,如果是结合spring定义的全局公用的线程池，还是不要随便shutdown。因为你不知道哪个任务因为你的shutdown而无法执行，保留几个核心线程还是很有必要的。

拓展

shutDown()

当线程池调用该方法时,线程池的状态则立刻变成SHUTDOWN状态。此时，则不能再往线程池中添加任何任务，否则将会抛出RejectedExecutionException异常。但是，此时线程池不会立刻退出，直到添加到线程池中的任务都已经处理完成，才会退出。

shutdownNow()

执行该方法，线程池的状态立刻变成STOP状态，并试图停止所有正在执行的线程，不再处理还在池队列中等待的任务，当然，它会返回那些未执行的任务。 它试图终止线程的方法是通过调用Thread.interrupt()方法来实现的，但是大家知道，这种方法的作用有限，如果线程中没有sleep 、wait、Condition、定时锁等应用, interrupt()方法是无法中断当前的线程的。所以，ShutdownNow()并不代表线程池就一定立即就能退出，它可能必须要等待所有正在执行的任务都执行完成了才能退出。