首先,我们要知道一些关于CountDownLatch的东西,不然不利于理解接下来的代码
CountDownLatch(int count) //实例化一个倒计数器,count指定计数个数
countDown() // 计数减一
await() //等待,当计数减到0时,所有线程并行执行,进行阻塞
接下来我们要做一个实验
public class TestController implements Runnable{
static int count = 0;
static CountDownLatch cdl = new CountDownLatch(2000);
static final TestController demo = new TestController();
public static void main(String[] args) throws Exception {
ExecutorService exec = Executors.newFixedThreadPool(1000);
for (int i = 0; i < 2000; i++) {
exec.submit(demo);
}
cdl.await();
System.out.println(count);
exec.shutdown();
}
public void run() {
for (int i=0;i<100;i++){
count++;
}
cdl.countDown();
}
}
上面的例子答案应该是200000 但是答案总是不是200000 为什么?
这就是经典的内存不可见的情况
每个线程都有自己的工作内存,每个线程需要对共享变量操作时必须先把共享变量从主内存 load 到自己的工作内存,等完成对共享变量的操作时再 save 到主内存。
问题就出在这了,如果一个线程运算完后还没刷到主内存,此时这个共享变量的值被另外一个线程从主内存读取到了,这个时候读取的数据就是脏数据了,它会覆盖其他线程计算完的值。。。
那么,我们能不能把volatile 加进来解决内存不可见问题呢?
不能!
因为 volatile 只能保证可见性,不能保证原子性。多个线程同时读取这个共享变量的值,就算保证其他线程修改的可见性,也不能保证线程之间读取到同样的值然后相互覆盖对方的值的情况。
解决方案
说了这么多,对于 i++ 这种线程不安全问题有没有其他解决方案呢?当然有,请参考以下几种解决方案。
1、对 i++ 操作的方法加同步锁,同时只能有一个线程执行 i++ 操作;
2、使用支持原子性操作的类,如 java.util.concurrent.atomic.AtomicInteger,它使用的是 CAS 算法,效率优于第 1 种;