【并发设计模式】聊聊两阶段终止模式如何优雅终止线程

在软件设计中，抽象出了23种设计模式，用以解决对象的创建、组合、使用三种场景。在并发编程中，针对线程的操作，也抽象出对应的并发设计模式。

两阶段终止模式- 优雅停止线程
避免共享的设计模式- 只读、Copy-on-write、Thread-Specific Storage
多线程版本的if模式
多线程分工模式 (Thread-per-Message 、Worker Thread、生产者-消费者模式)

从今天开始我们会开始逐篇讲解这几种并发设计模式。

最简单的方式其实就是调用线程的Stop方法，但是这个方法不推荐使用，原因是会直接将线程杀死。对于业务是不允许的。太粗暴了。

两阶段终止模式

两阶段终止模式其实就是将线程终止的过程分成两个过程。
第一个过程T1向线程T2发送终止指令，第二个过程T2响应终止指令。
在这里插入图片描述
但是本身线程想进入终止状态，那么必然要从运行状态转换，但是这个线程可能是休眠状态，block、wait、time_wait 三种状态。所以需要使用Thread类的interrupt()方法将线程从休眠状态转换到runnable状态。然后我们设置一个中断位，T2线程检查到需要终止就会直接停止。

一个案例

public class Proxy {

    private boolean isStart = false;
    // 对于stop的方法的修改 需要被start()方法 获取到，变量的可见性 
    private volatile boolean termial = false;
    private Thread runTask;

    synchronized void start () {

        runTask = new Thread(() -> {
            if (isStart) {
                return;
            }

            isStart = true;

            while (!Thread.currentThread().isInterrupted() || !termial) {
                try {
                    System.out.println("send->监控数据>监控平台");
                    TimeUnit.SECONDS.sleep(2);
                } catch (Exception e) {
                    Thread.currentThread().interrupt();
                    e.printStackTrace();
                }
            }

            isStart = false;
            System.out.println(Thread.currentThread().getName() + " stop");
        });

        runTask.start();
    }

    synchronized void stop () {
        runTask.interrupt();
        termial = true;
    }

}

终止线程池

对于终止线程池，shutdown()和shutdownNow() 前者其实会将线程池在处理以及阻塞队列中的任务处理完毕，后者会直接拒绝执行任何任务, shutdownNow的返回值是等得队列中未被执行的任务。所以在实际的使用中不推荐直接使用这两个方法。更优的方法其实是

		pool.shutdown();
        boolean terminated = false;
        while (!terminated) {
            pool.awaitTermination(100,TimeUnit.SECONDS);
        }

两阶段终止模式是一种应用很广泛的并发设计模式，在 Java 语言中使用两阶段终止模式来优雅地终止线程，需要注意两个关键点: 一个是仅检查终止标志位是不够的，因为线程的状态可能处于休眠态;另一个是仅检查线程的中断状态也是不够的，因为我们依赖的第三方类库很可能没有正确处理中断异常，例如第三方类库在捕获到 Thread.sleep() 方法抛出的中断异常后，没有重新设置线程的中断状态，那么就会导致线程不能够正常终止。所以我们可以自定义线程的终止标志位用于终止线程。