首页

通过AtomicInteger解决volatile多线程并发累计重叠覆盖现象情况

标签:AtomicInteger,volatile,多线程     发布时间:2022-12-07   

一、问题描述

多线程并发的环境下,java关键字volatile累加不能保证数据同步,会出现线程的读/写操作重叠现象(点击查看图文说明具体产生原因),如下图代码示例说明。

package com.xwood.demo.thread;@b@@b@public class TestVolatile_1 {@b@@b@    public static volatile int num = 0;@b@    public static void main(String[] args) throws Exception {@b@        for (int i = 0; i <100; i++) {@b@            new Thread(new Runnable() {@b@                @Override@b@                public void run() {@b@                    for (int i = 0; i <20000; i++) {@b@                        num++;//num++不是一个原子性操作@b@                    }@b@                }@b@            }).start();@b@        }@b@        Thread.sleep(3000);//休眠3秒,确保创建的100个线程都已执行完毕@b@        System.out.println(num);@b@    }@b@@b@}

控制台打印结果(逾期结果100*20000=2000000)

1900012

二、解决方法

通过AtomicInteger关键字解决不一致问题,具体代码效果如下(更多代码示例&教程请点击下载

package com.xwood.demo.thread;@b@@b@import java.util.concurrent.atomic.AtomicInteger;@b@@b@public class TestVolatile_2 {@b@    public static AtomicInteger num = new AtomicInteger(0);@b@    public static void main(String[] args) throws Exception {@b@        for (int i = 0; i <100; i++) {@b@            new Thread(new Runnable() {@b@                @Override@b@                public void run() {@b@                    for (int i = 0; i <20000; i++) {@b@                        num.incrementAndGet() ;// num自增,功能上相当于int类型的num++操作@b@                    }@b@                }@b@            }).start();@b@        }@b@        Thread.sleep(3000);//休眠3秒,确保创建的100个线程都已执行完毕@b@        System.out.println(num);@b@    }@b@}

控制台运行结果

2000000
@b@
<<热门下载>>