Executor 工作线程的 Java 内存一致性

Question

根据javadoc，实现Executor必须符合：

内存一致性效果：在将 Runnable 对象提交给 Executor 之前，线程 ( A ) 中的操作发生在其执行开始之前，可能在另一个线程 ( B ) 中。

由于我的英语很差，我不清楚B和随后由A提交给同一个 Executor 的另一个潜在线程C之间的内存一致性关系（如果有的话）。我希望下面的例子能澄清我的疑问。

import java.util.concurrent.Executor;

import java.util.concurrent.Executors;

class ExecutorTestClass {

    int a = 1;

    volatile boolean isDone = false;

    MyRunnable mr1 = new MyRunnable("One");

    MyRunnable mr2 = new MyRunnable("Two");

    class MyRunnable implements Runnable {

    private final String name;

    MyRunnable(String name) {

        this.name = name;

    }

    @Override

    public void run() {

        System.out.println(name + ": " + ExecutorTestClass.this.a++);

        isDone = true; // signal that addition has been performed

        while (true) {

        try {

            Thread.sleep(5); // busy thread

        } catch (InterruptedException e) {

        }

        }

    }

    }

    public static void main(String[] args) {

    ExecutorTestClass emc = new ExecutorTestClass();

    Executor executor = Executors.newFixedThreadPool(2);

    executor.execute(emc.mr1); // run the first MyRunnable

    while (!emc.isDone) {

    } // when stop spinning emc.a == 2 for this thread

    executor.execute(emc.mr2); // is emc.a == 2 guaranteed?

    }

}

保证emc.a == 2线程执行emc.mr2.run()？（在我的测试中这总是正确的，但是......是的，它们是测试）如果不是，官方 API 中是否有接口可以确保emc.a == 2？

Answer 1

不，不能保证，因为您emc.a在一个线程中更改值但从另一个线程提交Runnable。如果您在将第一个可运行对象设置为 2 之后从第一个可运行对象提交第二个可运行对象，则 JavaDoc 的内存一致性效果将适用。但是在您的示例中，即使不考虑 JavaDoc 中的注释，volatile变量的使用也会起到作用。isDone由于您首先递增emc.a，然后将新值设置为isDone然后检查isDone它是否会在关系之前建立，并且第二个可运行将始终看到更新的值。