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

m4299***

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次++操作，为什么结果是线程不安全的

pipe***

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

已有账号？

找人解决需求

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

全部参与1

热门问答

m4299***

今日需求悬赏

今日问答求助

发布任务需求已有1031167位用户正在使用天盟网服务

新手帮助

平台规则

关于天盟

一键快捷导航

微信公众号

手机客户端