多线程中的 AtomicLong

Question

我正在尝试在多线程环境中使用 AtomicLong。我想要的结果不起作用，

public class Account implements Runnable {

    private final AtomicLong amount = new AtomicLong(0);

    public Account(long difference) {
        amount.set(difference);
    }

    public void run() {
        System.out.println("The Balance is : " + amount);
    }
}

public class Examples {
    public static void main(String[] args) {
        ExecutorService service = Executors.newFixedThreadPool(10);
        IntStream.range(0, 100).forEach(i -> service.submit(new Account(i)));
    }
}

我尝试使用读/写锁和块级同步，但没有成功。请问有人发现哪里出错了吗？

I 输出必须从 0,1,2...99 开始。

Answer 1

您的任何线程之间没有共享数据...每个线程都创建自己的AtomicLong，没有共享。即使它是共享的，也不能保证这些数字会按顺序打印。它们甚至不能保证打印所有数字（其中一些可以打印多次）。

如果我这样更改您的代码：

public static class Account implements Runnable {
    private static final AtomicLong amount = new AtomicLong(0);

    public Account(long difference) {
        amount.set(difference);
    }

    public void run() {
        System.out.println("The Balance is : " + amount);
    }
}

这是我得到的输出示例：

The Balance is : 2
The Balance is : 2
The Balance is : 2
The Balance is : 4
The Balance is : 5
The Balance is : 6
The Balance is : 7
The Balance is : 8
The Balance is : 9
The Balance is : 9

原因是以下情况是可能的：

• 主线程创建Account(0)。这会将0 写入共享的AtomicLong。，
• Thread-0 启动
• 主线程创建Account(1)。这会将1 写入共享的AtomicLong。
• Thread-0 打印值，现在是 1。在这种情况下，0 将永远不会被打印出来。

AtomicLong 唯一能向您保证的是，所有对该值的写入将始终被之后进行读取的所有线程可见。

javadoc 中详细介绍了原子变量的属性（请参阅here）。

Answer 2

也许你的意思是这样的：

public class Account implements Runnable {

    private final static AtomicLong seq = new AtomicLong(0);
    private final long amount;

    public Account() {
        amount = seq.getAndIncrement();
    }

    public void run() {
        System.out.println("The Balance is : " + amount);
    }
}

public class Examples {
    public static void main(String[] args) {
        ExecutorService service = Executors.newFixedThreadPool(10);
        IntStream.range(0, 100).forEach(i -> service.submit(new Account()));
    }
}

这将保证每个帐户都将获得一个唯一的值amount，但这些值可以以不同的顺序打印。