java - 为什么下面代码子线程无法中断run方法中的while循环？

Question

题目描述

如题

题目来源及自己的思路

子线程修改condition值为false，run方法while循环终止。

相关代码

粘贴代码文本（请勿用截图）

public class VisibilityDemo {    private static volatile boolean condition = true;    static void run() {        while (condition) {            // do something            System.out.println("...");        }        System.out.println("退出");    }    public static void main(String[] args) {        run();        new Thread(() -> {            condition = false;        }).start();    }}

你期待的结果是什么？实际看到的错误信息又是什么？

期待：打印一段".."后打印"退出"。
实际：持续打印".."，不会打印"退出"。

Answer 1

run 不结束，不会执行到后面的 new Thread 。而 run 不会结束。

你可以把 run 也放到一个线程中去。

Answer 2

run死循环，不会走到new Thread

Answer 3

主线程一直在循环里面,没法执行到new thread(),换下顺序试下.

Answer 4

这个问题是关于Java多线程中volatile关键字和while循环的逻辑的。

在Java中，volatile关键字保证了变量的可见性和顺序性。但是，这并不能确保在某个时间点，当线程A修改了某个volatile变量的值后，线程B可以立即看到这个修改。

在你的代码中，while (condition)是在run方法中执行的，而new Thread(() -> { condition = false; })是在main方法中启动的。虽然condition被声明为volatile，但是在run方法中的while循环并不能保证每次都从主内存中读取最新的condition值。也就是说，在这个循环中，可能还会读取到旧的condition值（即true），然后继续执行循环。

因此，即使子线程将condition设为false，主线程的while循环可能仍然无法看到这个修改，也就无法退出。

一种解决这个问题的方法是使用Thread.join()方法。这个方法会让当前线程等待子线程结束。这样，主线程就能在子线程修改condition之后再去检查这个值。以下是修改后的代码：

public class VisibilityDemo {    private static volatile boolean condition = true;    static void run() {        while (condition) {            // do something            System.out.println("...");        }        System.out.println("退出");    }    public static void main(String[] args) {        new Thread(() -> {            try {                Thread.sleep(1000); // 让子线程先运行一段时间            } catch (InterruptedException e) {                e.printStackTrace();            }            condition = false;        }).start();        run();        try {            Thread.sleep(1000); // 让主线程等待子线程结束        } catch (InterruptedException e) {            e.printStackTrace();        }    }}

这段代码中，主线程会等待子线程结束后再开始执行run方法中的while循环，这样可以确保在子线程修改了condition之后再去检查这个值。所以，这个代码的输出应该是先打印一段"..."，然后打印"退出"。