以下代码片段使用AtomicInteger使用多个线程计数到1亿。我有10个Writer线程来模拟写入争用,有一个Reader线程来模拟读取争用。 Writer和Reader还共享一个易失性布尔变量作为毒丸。
但是,只有Reader线程能够退出而Writers不能退出。尽管将变量声明为volatile,为什么Reader线程不能看到更新的值?
public class AtomicRunnerV2 {
private static final int THREADS = 10;
private static final Integer MAX_COUNT = 100_000_000;
public static void main(String[] args) throws Exception {
AtomicInteger atomicInteger = new AtomicInteger(1);
Boolean data = new Boolean(false);
ExecutorService executorService = Executors.newFixedThreadPool(THREADS + 1);
for (int i = 0; i < THREADS; i++) {
executorService.submit(new Writer(atomicInteger, data));
}
executorService.submit(new Reader(atomicInteger, data));
executorService.shutdown();
}
static class Writer implements Runnable {
private AtomicInteger integer;
private volatile Boolean data;
Writer(final AtomicInteger integer, Boolean data) {
this.integer = integer;
this.data = data;
}
@Override public void run() {
while (!data) {
integer.incrementAndGet();
}
System.out.println("count " + integer.get() + " from WRITER!");
}
}
static class Reader implements Runnable {
private AtomicInteger integer;
private volatile Boolean data;
Reader(final AtomicInteger integer, Boolean data) {
this.integer = integer;
this.data = data;
}
@Override public void run() {
while (!data) {
if (integer.get() >= MAX_COUNT) {
data = true;
}
}
System.out.println("count " + integer.get() + " from READER!");
}
}
}
P.S:如果我将boolean包装在一个对象中,它就可以了。
你的volatile boolean data
不是参考,我认为你在这里建议,但副本。因此,Reader中的数据永远不会设置为false。如果你在Reader中使用Writer.data(并公开),这应该工作。
布尔值是不可变的。
data = true;
Writer中的上述行实际上创建了一个新的Boolean实例,从而导致读者永远不会看到新值,因为它们的布尔引用中没有“更新”。
通过使用下面的自定义类替换我的代码中的所有布尔值,并且Reader线程能够看到更新的值来测试它。
static class MyBoolean {
private boolean value;
MyBoolean(final boolean value) {
this.value = value;
}
boolean isValue() {
return value;
}
void setValue(final boolean value) {
this.value = value;
}
}