如果没有打印语句,循环看不到其他线程更改的值

2024-03-21

在我的代码中,我有一个循环等待其他线程更改某些状态。另一个线程可以工作,但我的循环从未看到更改后的值。它永远等待。然而,当我放一个System.out.println在循环中声明,它突然起作用了!为什么?


以下是我的代码示例:

class MyHouse {
    boolean pizzaArrived = false;

    void eatPizza() {
        while (pizzaArrived == false) {
            //System.out.println("waiting");
        }

        System.out.println("That was delicious!");
    }

    void deliverPizza() {
        pizzaArrived = true;
    }
}

当 while 循环运行时,我调用deliverPizza()从不同的线程来设置pizzaArrived多变的。但只有当我取消注释时循环才有效System.out.println("waiting");陈述。这是怎么回事?


JVM 可以假设其他线程不会改变pizzaArrived循环期间的变量。换句话说,它可以提升pizzaArrived == false在循环外进行测试,优化此:

while (pizzaArrived == false) {}

进入这个:

if (pizzaArrived == false) while (true) {}

这是一个无限循环。

为了确保一个线程所做的更改对其他线程可见,您必须始终添加一些同步线程之间。最简单的方法是创建共享变量volatile:

volatile boolean pizzaArrived = false;

制作一个变量volatile保证不同的线程能够看到彼此的更改的效果。这可以防止 JVM 缓存以下值pizzaArrived或将测试提升到循环之外。相反,它每次都必须读取实变量的值。

(更正式地说,volatile创建一个发生在之前变量访问之间的关系。这意味着线程所做的所有其他工作 https://stackoverflow.com/questions/19738651/volatile-variable-explanation-in-java-docs在交付披萨之前对于接收披萨的线程也是可见的,即使那些其他更改不volatile变量。)

同步方法 http://docs.oracle.com/javase/tutorial/essential/concurrency/syncmeth.html主要用于实现互斥(防止两件事同时发生),但它们也具有与volatile有。在读取和写入变量时使用它们是使更改对其他线程可见的另一种方法:

class MyHouse {
    boolean pizzaArrived = false;

    void eatPizza() {
        while (getPizzaArrived() == false) {}
        System.out.println("That was delicious!");
    }

    synchronized boolean getPizzaArrived() {
        return pizzaArrived;
    }

    synchronized void deliverPizza() {
        pizzaArrived = true;
    }
}

print语句的效果

System.out is a PrintStream目的。的方法PrintStream像这样同步:

public void println(String x) {
    synchronized (this) {
        print(x);
        newLine();
    }
}

同步可以防止pizzaArrived在循环期间被缓存。严格来讲,both线程必须在同一个对象上同步以保证变量的更改是可见的。 (例如,调用println设置后pizzaArrived并在阅读之前再次调用它pizzaArrived是正确的。)如果只有一个线程在某一特定对象上进行同步,则 JVM 可以忽略它。在实践中,JVM不够聪明,无法证明其他线程不会调用println设置后pizzaArrived,所以它假设他们可能会。因此,如果您调用,它无法在循环期间缓存变量System.out.println。这就是为什么像这样的循环在有 print 语句时可以工作,尽管这不是正确的解决方案。

Using System.out并不是导致这种效果的唯一方法,但这是人们在尝试调试循环不起作用的原因时最常发现的方法!


更大的问题

while (pizzaArrived == false) {}是一个忙等待循环。那很糟!在等待时,它会占用 CPU,从而减慢其他应用程序的速度,并增加系统的功耗、温度和风扇速度。理想情况下,我们希望循环线程在等待时休眠,这样它就不会占用 CPU。

以下是一些方法:

使用等待/通知

一个低级的解决方案是使用等待/通知方法Object https://stackoverflow.com/questions/2536692/a-simple-scenario-using-wait-and-notify-in-java:

class MyHouse {
    boolean pizzaArrived = false;

    void eatPizza() {
        synchronized (this) {
            while (!pizzaArrived) {
                try {
                    this.wait();
                } catch (InterruptedException e) {}
            }
        }

        System.out.println("That was delicious!");
    }

    void deliverPizza() {
        synchronized (this) {
            pizzaArrived = true;
            this.notifyAll();
        }
    }
}

在此版本的代码中,循环线程调用wait() http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html#wait--,这会使线程休眠。它在睡眠时不会使用任何 CPU 周期。第二个线程设置变量后,它调用notifyAll() http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html#notifyAll--唤醒正在等待该对象的任何/所有线程。这就像让披萨师傅按门铃,这样你就可以在等待时坐下来休息,而不是尴尬地站在门口。

当对一个对象调用 wait/notify 时,您必须持有该对象的同步锁,这就是上面代码的作用。你可以使用任何你喜欢的对象,只要两个线程使用同一个对象:这里我使用this(实例MyHouse)。通常,两个线程不能同时进入同一个对象的同步块(这是同步目的的一部分),但它在这里可以工作,因为线程在其内部时会暂时释放同步锁。wait() method.

阻塞队列

A BlockingQueue http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/BlockingQueue.html用于实现生产者-消费者队列。 “消费者”从队列的前面取出物品,“生产者”在队列的后面推送物品。一个例子:

class MyHouse {
    final BlockingQueue<Object> queue = new LinkedBlockingQueue<>();

    void eatFood() throws InterruptedException {
        // take next item from the queue (sleeps while waiting)
        Object food = queue.take();
        // and do something with it
        System.out.println("Eating: " + food);
    }

    void deliverPizza() throws InterruptedException {
        // in producer threads, we push items on to the queue.
        // if there is space in the queue we can return immediately;
        // the consumer thread(s) will get to it later
        queue.put("A delicious pizza");
    }
}

注:put and take的方法BlockingQueue可以扔InterruptedExceptions,这是必须处理的检查异常。在上面的代码中,为了简单起见,重新抛出了异常。您可能更愿意捕获方法中的异常并重试 put 或 take 调用以确保其成功。除了这一点丑之外,BlockingQueue非常容易使用。

这里不需要其他同步,因为BlockingQueue确保线程在将项目放入队列之前所做的一切对于取出这些项目的线程可见。

执行者

Executors 就像现成的BlockingQueue执行任务的s。例子:

// A "SingleThreadExecutor" has one work thread and an unlimited queue
ExecutorService executor = Executors.newSingleThreadExecutor();

Runnable eatPizza = () -> { System.out.println("Eating a delicious pizza"); };
Runnable cleanUp = () -> { System.out.println("Cleaning up the house"); };

// we submit tasks which will be executed on the work thread
executor.execute(eatPizza);
executor.execute(cleanUp);
// we continue immediately without needing to wait for the tasks to finish

有关详细信息,请参阅文档Executor http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/Executor.html, ExecutorService http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/ExecutorService.html, and Executors http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/Executors.html.

事件处理

在等待用户单击 UI 中的某些内容时循环是错误的。相反,请使用 UI 工具包的事件处理功能。In Swing http://docs.oracle.com/javase/tutorial/uiswing/events/index.html, 例如:

JLabel label = new JLabel();
JButton button = new JButton("Click me");
button.addActionListener((ActionEvent e) -> {
    // This event listener is run when the button is clicked.
    // We don't need to loop while waiting.
    label.setText("Button was clicked");
});

由于事件处理程序在事件分派线程上运行,因此在事件处理程序中执行长时间工作会阻塞与 UI 的其他交互,直到工作完成。慢速操作可以在新线程上启动,或者使用上述技术之一(等待/通知、BlockingQueue, or Executor)。您还可以使用SwingWorker http://docs.oracle.com/javase/tutorial/uiswing/concurrency/worker.html,它就是专门为此设计的,并自动提供后台工作线程:

JLabel label = new JLabel();
JButton button = new JButton("Calculate answer");

// Add a click listener for the button
button.addActionListener((ActionEvent e) -> {

    // Defines MyWorker as a SwingWorker whose result type is String:
    class MyWorker extends SwingWorker<String,Void> {
        @Override
        public String doInBackground() throws Exception {
            // This method is called on a background thread.
            // You can do long work here without blocking the UI.
            // This is just an example:
            Thread.sleep(5000);
            return "Answer is 42";
        }

        @Override
        protected void done() {
            // This method is called on the Swing thread once the work is done
            String result;
            try {
                result = get();
            } catch (Exception e) {
                throw new RuntimeException(e);
            }
            label.setText(result); // will display "Answer is 42"
        }
    }

    // Start the worker
    new MyWorker().execute();
});

Timers

要执行定期操作,您可以使用java.util.Timer http://docs.oracle.com/javase/8/docs/api/java/util/Timer.html。它比编写自己的定时循环更容易使用,并且更容易启动和停止。该演示每秒打印一次当前时间:

Timer timer = new Timer();
TimerTask task = new TimerTask() {
    @Override
    public void run() {
        System.out.println(System.currentTimeMillis());
    }
};
timer.scheduleAtFixedRate(task, 0, 1000);

Each java.util.Timer有自己的后台线程,用于执行其预定的TimerTasks。当然,线程在任务之间会休眠,因此不会占用 CPU。

在Swing代码中,还有一个javax.swing.Timer http://docs.oracle.com/javase/tutorial/uiswing/misc/timer.html,类似,但它在 Swing 线程上执行监听器,因此您可以安全地与 Swing 组件交互,而无需手动切换线程:

JFrame frame = new JFrame();
frame.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
Timer timer = new Timer(1000, (ActionEvent e) -> {
    frame.setTitle(String.valueOf(System.currentTimeMillis()));
});
timer.setRepeats(true);
timer.start();
frame.setVisible(true);

其他方法

如果您正在编写多线程代码,则值得探索这些包中的类以查看可用的内容:

  • java.util.concurrent http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/package-summary.html
  • java.util.concurrent.atomic http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/atomic/package-summary.html
  • java.util.concurrent.locks http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/locks/package-summary.html

并且还可以看到并发部分 http://docs.oracle.com/javase/tutorial/essential/concurrency/index.htmlJava 教程。多线程很复杂,但有很多帮助可用!

本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)

如果没有打印语句,循环看不到其他线程更改的值 的相关文章

  • Android 中的列表(特别是 RecyclerView 和 CardView)如何工作

    请原谅我问这个问题 但我是 Android 开发新手 尽管我正在尝试了解developer android com 网站上的基础知识 但大多数示例 即使他们说它们是为 Android Studio 构建的 尚未设置为使用 Gradle 因此
  • Oracle Java 教程 - 回答问题时可能出现错误

    我是 Java 新手 正在阅读 Oracle 教程 每个部分之后都有问题和答案 我不明白一个答案中的一句话 见下面的粗体线 来源是https docs oracle com javase tutorial java javaOO QandE
  • 如何在 Openfire 中使用 smack

    你好 我计划开发一个可以连接到 gtalk facebook 等的聊天客户端 我决定将 smack API 与 openfire 一起使用 但我需要很少的指导来了解如何将它与 openfire 服务器一起使用 openfire 是否提供了基
  • 如何使用 JAVA 代码以编程方式捕获线程转储?

    我想通过 java 代码生成线程转储 我尝试使用 ThreadMXBean 为此 但我没有以正确的格式获得线程转储 因为我们正在使用jstack命令 请任何人提供一些帮助 他们是否有其他方式获取线程转储 使用任何其他 API 我想要的线程转
  • (Java) App Engine 中的静态文件无法访问

    The 示例文档 http code google com appengine docs java gettingstarted staticfiles html表示您只需将文件放在 war 或子目录 中 并且应该可以从主机访问它们 只要它
  • HAProxy SSL终止+客户端证书验证+curl/java客户端

    我希望使用我自己的自签名证书在 HAProxy 上进行 SSL 终止 并使用我创建的客户端证书验证客户端访问 我通过以下方式创建服务器 也是 CA 证书 openssl genrsa out ca key 1024 openssl req
  • 从 MS Access 中提取 OLE 对象(Word 文档)

    我有一个 Microsoft Access 数据库 其中包含一个包含 Microsoft Word 文档的 OLE 对象字段 我试图找到代码来检索保存在 OLE 对象中的文件 以便用户可以从我的 JavaFx 应用程序中的按钮下载它 但没有
  • FileNotFoundException - Struts2 文件上传

    Strange FileNotFoundException使用Struts2上传文件时 这是 JSP 的一部分
  • 为什么 MOVE CURSOR 在 OS X Mountain Lion 上不显示?

    我正在做一个项目 想看看 Swing 提供的每个光标是什么样子的 public class Test public static void main String args JFrame frame new JFrame frame set
  • 为什么Iterator接口没有add方法

    In IteratorSun 添加了remove 方法来删 除集合中最后访问的元素 为什么没有add方法来向集合中添加新元素 它可能对集合或迭代器产生什么样的副作用 好的 我们开始吧 设计常见问题解答中明确给出了答案 为什么不提供 Iter
  • 虽然我的类已加载,但 Class.forName 抛出 ClassNotFoundException

    代码如下 它的作用是加载我放在主目录中的 jar 文件中的所有类 import java io File import java util jar JarFile import java util jar JarEntry import j
  • 关于逻辑/算法的想法以及如何防止线程写入 Sql Server 中的竞争

    我有以下逻辑 public void InQueueTable DataTable Table int incomingRows Table Rows Count if incomingRows gt RowsThreshold async
  • 如何从日期中删除毫秒、秒、分钟和小时[重复]

    这个问题在这里已经有答案了 我遇到了一个问题 我想比较两个日期 然而 我只想比较年 月 日 这就是我能想到的 private Date trim Date date Calendar calendar Calendar getInstanc
  • 寻找局部最小值

    下面的代码正确地找到了数组的局部最大值 但未能找到局部最小值 我已经进行了网络搜索 以找到找到最小值的最佳方法 并且根据这些搜索 我认为我正在使用下面的正确方法 但是 在几天的时间里多次检查每一行之后 下面的代码中有一些我仍然没有看到的错误
  • 如何通过 Android 按钮单击运行单独的应用程序

    我尝试在 Android 应用程序中添加两个按钮 以从单独的两个应用程序订单系统和库存系统中选择一个应用程序 如图所示 我已将这两个应用程序实现为两个单独的 Android 项目 当我尝试运行此应用程序时 它会出现直到正确选择窗口 但是当按
  • 如何停止执行的 Jar 文件

    这感觉像是一个愚蠢的问题 但我似乎无法弄清楚 当我在 Windows 上运行 jar 文件时 它不会出现在任务管理器进程中 我怎样才能终止它 我已经尝试过 TASKKILL 但它对我也不起作用 On Linux ps ef grep jav
  • 替换文件中的字符串

    我正在寻找一种方法来替换文件中的字符串而不将整个文件读入内存 通常我会使用 Reader 和 Writer 即如下所示 public static void replace String oldstring String newstring
  • 何时在 hibernate 中使用 DiscriminatorValue 注解

    在 hibernate 中使用 DiscriminatorValue 注释的最佳场景是什么以及何时 这两个链接最能帮助我理解继承概念 http docs oracle com javaee 6 tutorial doc bnbqn html
  • 使用 JFreeChart 为两个系列设置不同的 y 轴

    我正在使用 JFreeChart 使用折线图绘制两个数据系列 XYSeries 复杂的因素是 其中一个数据系列的 y 值通常远高于第二个数据系列的 y 值 假设第一个系列的 y 值约为数百万数量级 而第二个数据系列的 y 值约为数百万数量级
  • 如何使用通配符模拟泛型方法的行为

    我正在使用 EasyMock 3 2 我想基于 Spring Security 为我的部分安全系统编写一个测试 我想嘲笑Authentication http docs spring io autorepo docs spring secu

随机推荐

  • ipython笔记本单元格的背景颜色

    如何更改 iPython Notebook 中特定单元格的背景颜色 例如 我正在编写一本手册 我想在灰色文本框中添加一些终端命令 如下所示http ipython org ipython doc 1 interactive nbconver
  • React Native - 如何像 iOS 或 Instagram 一样进行模糊视图?

    模糊背景透明度 是否可以在不使用背景图像的情况下模糊视图 我想展示家长内容在上面背景模糊视图 in modal 类似这样的 尝试过反应本机模糊 https github com react native community react na
  • Linq lambda 表达式 - 查找一周中距离当前日期(现在)最近的一天

    例如 我将星期一 星期四和星期日作为抽奖日期 使用 Linq Lambda 查找与 Datetime Now 最接近的 dayOfWeek 的方法是什么 我使用正常功能完成了此操作 但我想知道如何使用 Linq Lambda 来完成此操作
  • 在 webapp 中优雅地关闭 ExecutorService?

    在我的网络应用程序中 我创建了一个使用ExecutorService具有固定大小的线程池 我重复使用相同的ExecutorService在整个应用程序生命周期内 private static ExecutorService pool Exe
  • 如何创建一个内容为表达式结果的有限迭代器?

    我想创建一个Iterator通过 重复 评估表达式来获取下一个元素 并且我希望表达式能够返回某个值来终止它 我唯一发现的就是这样迭代器 continually http www scala lang org api current inde
  • Python有限差分函数?

    我一直在 Numpy Scipy 中寻找包含有限差分函数的模块 然而 我发现的最接近的是numpy gradient 这对于二阶精度的一阶有限差分很有用 但如果您想要更高阶的导数或更准确的方法 则效果不太好 我什至还没有找到很多专门用于此类
  • 如何在客户端读取excel文件内容?

    在 JSP 页面中 我需要浏览 excel 文件 在系统上选择文件后 我需要读取该 excel 文件内容并填写表格 目前我已经尝试使用下面的代码 但它只能在 IE 中工作 并对 ActiveXObject 的 IE Internet 选项进
  • 使用 java poi 从 Office 2007+ 文档中读取属性集

    我尝试从 Office 2007 文档 docx xlsx 读取属性集 找到了惊人的解决方案http poi apache org hpsf how to html http poi apache org hpsf how to html
  • postgresql 生成无间隙的序列

    我必须 必须为发票创建唯一的 ID 我有一个表 ID 和这个唯一编号的另一列 我使用序列化隔离级别 使用 var seq SELECT invoice serial 1 FROM invoice WHERE type type ORDER
  • 导航器.userAgent

    我正在尝试检测浏览器是否是 Safari 如果是这样 那就做点什么吧 在所有其他浏览器中 执行其他操作 if navigator userAgent toLowerCase indexOf safari 1 if safari execut
  • 感叹号在数据类型中起什么作用?

    我是 Haskell 的新手 今天我阅读了 OpenGL 源代码 发现了这个 data VertexArrayDescriptor a VertexArrayDescriptor NumComponents DataType Stride
  • 使用 jQuery 获取元素的真实宽度

    我正在为 html 文件的 视觉正确性 编写一个验证器 目标是检测太宽的元素 这是我的问题的演示 http jsfiddle net vv68y 2 红色虚线表示文档的最大宽度 本例中为 200px 第一段很好 但第二段太宽了 尽管如此 以
  • 刷新所有 Azure 实例上的数据

    刷新所有 Azure 实例中的数据的最佳方法是什么 我有多个实例 每个实例都运行相同的 Web 角色 角色启动时 数据从 Blob 存储读取到本地存储 网站使用的数据会间歇性地有新的更新 我希望能够以编程方式通知每个实例 以将更新的数据从
  • 如何在Terraform中输出一种类型的所有资源?

    我有一堆aws ecr repositories在我的 Terraform 代码中定义 resource aws ecr repository nginx images name nginx test resource aws ecr re
  • 获取字符串形式的属性名称

    我需要一种方法来传递属性并获取分配给它的名称 有什么建议么 property nonatomic retain MyObject crazyObject NSString str SOME WAY TO GET PROPERTY NAME
  • 设置可选参数默认值的 phpdoc 标准?

    Example This function will determine whether or not one string starts with another string param string haystack p The st
  • 如何在 Objective-C 中内联声明好的旧 C 数组?

    这是我的代码 NSUInteger indexArr 1 2 3 4 NSIndexSet indexSet NSIndexPath indexPathWithIndexes indexArr length 4 有没有办法声明indexAr
  • BEM 块、命名和嵌套

    我正在尝试了解 BEM 命名约定 我被困在这个问题上 我可能误解了一些东西 让我们看看 我有一个侧边栏导航和一个内容导航 我的侧边栏导航看起来像这样 div class sidebar ul class sidebar nav li cla
  • Eclipse 作为 IDE + Mercurial 用于版本控制 + ?错误跟踪 = 好主意? [关闭]

    Closed 这个问题是基于意见的 help closed questions 目前不接受答案 对于一个新的 Java Web 项目 我考虑使用 Eclipse 作为 IDE Mercurial 用于版本控制 某种错误跟踪软件 我听说过错误
  • 如果没有打印语句,循环看不到其他线程更改的值

    在我的代码中 我有一个循环等待其他线程更改某些状态 另一个线程可以工作 但我的循环从未看到更改后的值 它永远等待 然而 当我放一个System out println在循环中声明 它突然起作用了 为什么 以下是我的代码示例 class My