【面试：并发篇26：多线程：两阶段终止模式】volatile版本

00.前言

如果有任何问题请指出，感谢。

01.介绍

可以与这个文章中的两阶段终止模式进行对比https://blog.csdn.net/m0_71229547/article/details/125656363?spm=1001.2014.3001.5501

02.代码

@Slf4j(topic = "c.TwoPhaseTermination")
public class Test13 {
    public static void main(String[] args) throws InterruptedException {
        TwoPhaseTermination tpt = new TwoPhaseTermination();
        tpt.start();

        Thread.sleep(3500);
        log.debug("停止监控");
        tpt.stop();
    }
}

@Slf4j(topic = "c.TwoPhaseTermination")
class TwoPhaseTermination {
    // 监控线程
    private Thread monitorThread;
    // 停止标记
    private volatile boolean stop = false;

    // 启动监控线程
    public void start() {
        monitorThread = new Thread(() -> {
            while (true) {
                if (stop) {
                    log.debug("料理后事");
                    break;
                }
                try {
                    Thread.sleep(1000);
                    log.debug("执行监控记录");
                } catch (Exception e) {
                }
            }
        }, "monitor");
        monitorThread.start();
    }

    // 停止监控线程
    public void stop() {
        stop = true;
        monitorThread.interrupt();

    }
}
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
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44

结果

17:32:07.094 c.TwoPhaseTermination [monitor] - 执行监控记录
17:32:08.108 c.TwoPhaseTermination [monitor] - 执行监控记录
17:32:09.109 c.TwoPhaseTermination [monitor] - 执行监控记录
17:32:09.585 c.TwoPhaseTermination [main] - 停止监控
17:32:09.585 c.TwoPhaseTermination [monitor] - 料理后事

解释
与之前的不同点是：这里我们利用的是静态变量stop进行是否还监控的判断，但是一个线程一直读 另一个线程写，势必会导致可见性问题，所以我们用了volatile修饰stop，另外如果我们在sleep期间 主线程把stop改为了true 那么我们还是需要等待sleep完才可以进行是否退出的判断，所以我们主线程的stop方法里面不仅改变了stop的值 还顺便把监控线程打断 避免了上述sleep的问题。