AtomicInteger真的产生原子整数吗？

Question

public class TestAtomicInteger {

public static void main(String[] args) {

    final AtomicInteger sequencer = new AtomicInteger(1);
    final Set<Integer> integers = new HashSet<>();
    //final Set<Integer> integers = new ConcurrentSkipListSet<>();


    final Runnable task = new Runnable() {

        @Override
        public void run() {
            int next = sequencer.getAndIncrement();
            integers.add(next);
            System.out.println(integers.size());
        }
    };
    for (int i = 0; i < 1000; i++) {
        Thread t = new Thread(task);
        t.start();
    }
}
}

有人解释一下为什么吗？多谢了。

*注意：在运行函数中。如果我使用System.out.println（next）；有时我也会看到一些丢失的测序器。*

示例输出1：

Answer 1

代码的一个主要问题是将数字添加到不是线程安全的hashset中。这就是你所观察的原因。如果使用线程安全集合,则会得到预期的结果：

final Set<Integer> integers = new ConcurrentSkipListSet<>();

但这引入了一个额外的同步层。另一种选择是使用普通数组int[]numbers=new int[1000]；并使用:numbers[next-1]++；来计算发生的次数。

供参考的新代码：

public static void main(String[] args) throws Exception {

    final AtomicInteger sequencer = new AtomicInteger(1);
    final int[] integers = new int[1000];

    final Runnable task = new Runnable() {

        @Override
        public void run() {
            int next = sequencer.getAndIncrement();
            integers[next-1]++;
        }
    };
    List<Thread> threads = new ArrayList<>();
    for (int i = 0; i < 1000; i++) {
        Thread t = new Thread(task);
        t.start();
        threads.add(t);
    }
    for (Thread t : threads) {
        t.join();
    }
    for (int i = 0; i < 1000; i++) {
        if (integers[i] != 1) System.out.println(i + " -> " + integers[i]);
    }
}