为什么这段断码是线程不安全的？

Question

public class ThreadTest {

    private static int threadTotal = 200;

    private static int clientTotal = 5000;

    private static int count = 0;

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

        ExecutorService executorService = Executors.newCachedThreadPool();
        final Semaphore semaphore = new Semaphore(threadTotal);
        final CountDownLatch countDownLatch = new CountDownLatch(clientTotal);

        for (int i = 0; i < clientTotal; i++) {

            executorService.execute(() -> {
                try {
                    semaphore.acquire();
                    ++count;
                    semaphore.release();
                    countDownLatch.countDown();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            });
        }
        countDownLatch.await();
        System.out.println(count);

        executorService.shutdown();

    }
}

这段代码操作的是一个static 变量，5000个线程执行了5000次++操作，为什么结果是线程不安全的

Answer 1

++count的操作实际是三个操作1 cpu从内存读取count2 cpu内部更改count3 cpu写入count多线程的时候，可能会有100个线程同时读取的值都是0，那么他们++之后写回去当然就是1，而不是100 。同时在cpu写入的时候，也不是实时写入，而是在cpu高速缓存内，所以各个线程内的count数值是不一样的。要保证读写一致性，需要加入同步的方法来操作。这里只是对count一个变量做++运算，可以用CAS或者锁。当然JAVA里面的变量属性 volatile 也是可以保证单个数字更新同步的效果。这里 new Semaphore(1); 也可以限制同时只能有一个线程进入++count操作，也能达到线程安全的目的。