关于java-ee:优雅关闭线程池的方案

3次阅读

共计 2692 个字符，预计需要花费 7 分钟才能阅读完成。

咱们常常在我的项目中应用的线程池，然而是否关怀过线程池的敞开呢，可能很多时候间接再我的项目中间接创立线程池让它始终运行当工作执行完结不在须要了也不去敞开，这其实是存在十分大的危险的，大量的线程常驻在后盾对系统资源的占用是微小的，甚至引发异样。所以在咱们平时应用线程池时须要留神优雅的敞开，这样能够保障资源的管控。
在 Java 中和敞开线程池相干的办法次要有如下：
- void shutdown()
- List<Runnable> shutDownNow
- boolean awaitTermination
- boolean isShutDown
- boolean isTerminated
对于这些办法有着不同的应用和作用，上面咱们真的会这些不同的办法做具体的介绍。

shutDown 办法从字面意思咱们能够看到是进行敞开的意思，咱们先来看上面的一段代码，首先咱们通过 ThreadPoolExecutor 来创立一个容量是 10 的无界限程池，与 FixedThreadPool 相似的，这里手动创立能够更好地了解线程池的创立。在后咱们提交一千个工作执行，再执行 shutdown 办法进行暂停。

 public static void main(String[] args) throws InterruptedException {

        ExecutorService service = new ThreadPoolExecutor(
                10,
                10,
                0L,
                TimeUnit.MILLISECONDS,
                new LinkedBlockingQueue<>());

        for (int i = 0; i < 1000; i++) {service.submit(() ->{
                try {TimeUnit.SECONDS.sleep(1);
                } catch (InterruptedException e) {System.out.println("承受中断，不解决~~");
                }
                System.out.println("args =" + Arrays.deepToString(args)+ Thread.currentThread().getName());
            });
        }

        service.shutdown();}

咱们能够看到后果所以线程会失常执行完结后再敞开线程池，对于 ShutDown 而言它能够平安的进行一个线程池，它有几个关键点
ShutDown 会首先将线程设置成 SHUTDOWN 状态，而后中断所有没有正在运行的线程
正在执行的线程和曾经在队列中的线程并不会被中断，说白了就是应用shutDown 办法其实就是要期待所有工作失常全副完结当前才会敞开线程池
调用 shutdown() 办法后如果还有新的工作被提交，线程池则会依据回绝策略间接回绝后续新提交的工作。

这个办法与下面办法相比拟，直观就是 now，即立刻进行工作，
同样是上述案列，略作批改如下，

public static void main(String[] args) throws InterruptedException {

        ExecutorService service = new ThreadPoolExecutor(
                10,
                10,
                0L,
                TimeUnit.MILLISECONDS,
                new LinkedBlockingQueue<>(1000));

        for (int i = 0; i < 1000; i++) {service.submit(() ->{
                try {TimeUnit.SECONDS.sleep(1);
                } catch (InterruptedException e) {System.out.println("承受中断，完结线程~~");
                    // 这里响应中断
                    return;
                }
                System.out.println("args =" + Arrays.deepToString(args)+ Thread.currentThread().getName());
            });
        }

      final List<Runnable> runnables = service.shutdownNow();
       System.out.println(runnables);
    }

执行上述代码咱们发现，当执行 shutDownNow 办法后，会像全副正在运行的队列告诉中断，正在运行的线程接管到中断信号后抉择解决，而在队列中的全副勾销执行转移到一个list 队列中返回，如上述 List<Runnable> runnables，这里记录了所有终止的线程

这个办法并不是用来敞开线程池的，首先咱们看一下这个办法的定义：

boolean awaitTermination_(_long timeout, TimeUnit unit_)_

能够看到这个办法有两个参数，timeout 示意期待的工夫，unit 工夫单位
这个办法的作用是，调用后期待 timeout 工夫后，反馈线程池的状态，
期待期间（包含进入期待状态之前）线程池已敞开并且所有已提交的工作（包含正在执行的和队列中期待的）都执行结束，相当于线程池曾经“终结”了，办法便会返回 true；
期待超时工夫到后，第一种线程池“终结”的状况始终未产生，办法返回 false；
期待期间线程被中断，办法会抛出 InterruptedException 异样。
下面代码能够批改来测试，这里不再粘贴代码

isShutDown 办法正如名字，判断线程池是否进行，返回的是 Boolean 类型，如果曾经开始进行线程池则返回 true 否则放回 false
当调用了shutDown 或shutDownNow 时之后，会返回 true 不过须要留神，这时候只是代表线程池敞开流程的开始，并不是说线程池曾经进行了

这个办法与下面的办法的区别就是这是正真检测线程池是否真的终结了
这不仅代表线程池已敞开，同时代表线程池中的所有工作都曾经都执行结束了，因为在调用 shutdown 办法之后，线程池会继续执行外面未实现的工作，包含正在执行的工作和在工作队列中期待的工作。
如果调用了 shutdown 办法，然而有一个线程仍然在执行工作，那么此时调用 isShutdown 办法返回的是 true，而调用 isTerminated办法返回的便是 false，因为线程池中还有工作正在在被执行，线程池并没有真正“终结”。
直到所有工作都执行结束了，调用 isTerminated() 办法才会返回 true，这示意线程池已敞开并且线程池外部是空的，所有残余的工作都执行结束了。