可运行的无限循环消失了吗？

Question

一些简化的代码来说明我的问题：

public class QueriesQueueRunnable implements Runnable {

    private List<String> queue = new ArrayList<String>();


    @Override
    public void run() {
        while(true){
            if (!this.getQueue().isEmpty()) {
                    System.out.println(this.getQueue().get(0));
                    this.getQueue().remove(0);

            }
        }
    }
}

---

QueriesQueueRunnable queriesQueueRunnable = new QueriesQueueRunnable();
Thread thread = new Thread(queriesQueueRunnable).start();




for (int i = 0; i < 1000; i++) {
     if(i==500){
         try {
                Thread.sleep(5000);                 
            } catch(InterruptedException ex) {
                Thread.currentThread().interrupt();
            }
     }
    queriesQueueRunnable.getQueue().add(String.valueOf(i));
}

输出仅在 i==499 迭代之前显示。为什么？这就像执行超出了可运行循环。

Java 1.7

Answer 1

当您的代码是sleeping 时，另一个线程无休止地旋转，毫无结果，使其容易受到 JIT 编译器的优化。由于该线程无法知道 queue 正在更新，因此优化器假定 queue.isEmpty() 将永远返回 true 并完全跳过检查。

避免这个问题的一种方法是使queue字段volatile，它通知JVM其他线程可以同时修改值：

private volatile List<String> queue = new ArrayList<String>();

请注意，尽管这将解决您的特定问题，但您的代码仍远非线程安全，因为ArrayList 并不意味着并发访问。

还请注意，您的程序永远不会完成，除非您将辅助线程设为 daemon thread。