Java并发中的可见性和原子性

简介: Java并发中的可见性和原子性

一、可见性



1、实例讲解


先看这样一段代码:

public class Test {
  static boolean a = true;
  public static void main(String[] args) {
    a = false;          //对a执行写操作
    System.out.println(a);    //对a执行读操作
  }
}


f1d77287d3914ab9b8def869d22efd9c.png


我们在单线程中,对a执行了写操作,并且读取到了最新写的值,也就是说,单线程中对a的写操作时可见的。


那么我们再开启一个线程 :

public class Test {
  static boolean a = true;
  public static void main(String[] args) throws InterruptedException {
    new Thread(()-> {
      while(a) {} //死循环
    }).start();
    Thread.sleep(1000); //为了保证不会影响,停一秒再写    
    a = false;          //对a执行写操作
    System.out.println(a);    //对a执行读操作
  }
}


cc57a8af1dfd4bde82cdf8beb968d9e6.png


可以看到,虽然a仍然打印出为false,但是程序没有结束,就说明在我们新开启的线程中a的值始终为true,他才可以一直执行while循环。换句话说,我们的主线程对a的写操作对于新开的线程的读操作来说是不可见的。


为什么这么长时间了,新开线程中的a还是true呢?那是因为新线程中一直在执行循环,使得线程没有机会去拿到主存中a的最新值,而是一直读取缓存中a的值。


那么,我们让循环沉睡一会儿,给他去读最新值的机会:


public class Test {
  static boolean a = true;
  public static void main(String[] args) throws InterruptedException {
    new Thread(()-> {
      while(a) {
        try {
          Thread.sleep(1);  //睡1ms,给线程去读新值的机会
        } catch (InterruptedException e) {
          e.printStackTrace();
        }
      } //死循环
    }).start();
    Thread.sleep(1000); //为了保证不会影响,停一秒再写    
    a = false;          //对a执行写操作
    System.out.println(a);    //对a执行读操作
  }
}


91fe63e00df8484bb87b4c17bc5f255b.png


可以看到,程序很快就结束了,说明新线程已经读到了a的新值为false,结束了循环。


2、如何理解Java线程中的不可见性?


简单来说:线程1读,线程2写,而线程1读不到线程2写的值,这就是不可见性。


3、那么如何实现可见性呢?


就需要用到volatile关键字了:


public class Test {
  static volatile boolean a = true;
  public static void main(String[] args) throws InterruptedException {
    new Thread(()-> {
      while(a) {} //死循环
    }).start();
    Thread.sleep(1000); //为了保证不会影响,停一秒再写    
    a = false;          //对a执行写操作
    System.out.println(a);    //对a执行读操作
  }
}


a0a1288a0b0c486a8d48fb0338b06c0b.png


二、原子性



保证可见性可以保证一个线程写之后,另一个线程可以读到。


那假如一个进程既读取变量,又依赖读到的变量进行写操作呢?我们来看下面的例子 :


1、实例讲解


用两个线程分别执行10000次a++的操作,按道理来说,a的结果应该会增加20000


public class Test {
  static int a = 0;
  public static void main(String[] args) throws InterruptedException {
    for(int i=0; i<10000; i++) {
      new Thread(()-> {
        a++;
      }).start();
      new Thread(()-> {
        a++;
      }).start();
    }   
    Thread.sleep(1000); //为了保证不会影响,停一秒再写    
    System.out.println(a);    //对a执行读操作
  }
}


4ae4bc43f4ae4bd3a2297209007c4f4a.png

可以看到,结果和我们的预期对不上,那我们加上volatile关键字试一下:


bf020e6b3b124949bbb0a5b659f6db9b.pngd1b6dd17895245a38eee877778cea203.png

结果还是对不上,这是为什么呢?

这就要探究a++的本质了


2、a++的本质

     

a++可以拆分为三个操作:1、读取a; 2、a+1; 3、将加之后的值赋给a


有可能会出现这种情况:


       1、当a=0时,线程1读取a值,线程2也读取a值;

       2、线程1将它读到的a值+1,此时为1,线程2也将它读到的a值+1,此时为1;

       3、线程1将1这个值刷入主存,此时主存中的a=1;线程2也将1这个值刷入主存,此时为1


这显然是不对的,两个线程各执行一次a++,a的值应该+2才对。刚刚我们得到的值为19998,可能就是有两个线程在其他线程+之前读取到了a值。


那加上volatile关键字之后呢?


volatile关键字只能保证可见性,即一个线程写过之后,另一个线程能够立马读到。而假如线程2操作在线程1操作写之前就已经读了,那还是没办法改变这个情况。这两个线程都需要读取主存的值,并且每个线程都依赖自己读取的值进行写操作。这就需要保证原子性了。


3、使用Atomicxxxx保证原子性:


public class Test {
  static AtomicInteger a = new AtomicInteger(0);
  public static void main(String[] args) throws InterruptedException {
    for(int i=0; i<10000; i++) {
      new Thread(()-> {
        a.getAndAdd(1);
      }).start();
      new Thread(()-> {
        a.getAndAdd(1);
      }).start();
    }   
    Thread.sleep(1000); //为了保证不会影响,停一秒再写    
    System.out.println(a);    //对a执行读操作
  }
}


540047ec940743c988600d02d3a63dd0.png

可以看到,a++的操作改成了getAndAdd(),读和写是一起执行的,这就不会在读值之后写值之前被其他线程插一杠子。


需要注意的一点是,原子性和可见性并不是相互独立的,保证原子性的前提是保证可见性,那为什么我们没有再用volatile修饰a来保证可见性呢?这就需要去看看AtomicInteger的源码了:

6e7d51c461154ee2af35713e6192ec2f.png


其实它的内部也使用了volatile关键字。


4、使用synchronized同步代码段强制实现原子性和可见性


除了Atomic,也可以使用synchronized同步代码段强制实现原子性。


public class Test {
  static AtomicInteger a = new AtomicInteger(0);
  static int b = 0;
  public static void main(String[] args) throws InterruptedException {
    for(int i=0; i<10000; i++) {
      new Thread(()-> {
//        a.getAndAdd(1);
        synchronized(Test.class) {
          b++;
        }
      }).start();
      new Thread(()-> {
//        a.getAndAdd(1);
        synchronized(Test.class) {
          b++;
        }
      }).start();
    }   
    Thread.sleep(1000); //为了保证不会影响,停一秒再写    
//    System.out.println(a);    //对a执行读操作
    System.out.println(b);    //对b执行读操作
  }
}


相比较Atomic,synchronized就更加重量级了。


另外:volatile不具有传染性,用volatile修饰的对象的内部属性不具有可见性,反之用volatile修饰的内部属性也不能保证所在对象的可见性。


参考:【java】并发之可见性与原子性_哔哩哔哩_bilibili 




相关文章
|
4月前
|
Java 大数据 Go
从混沌到秩序:Java共享内存模型如何通过显式约束驯服并发?
并发编程旨在混乱中建立秩序。本文对比Java共享内存模型与Golang消息传递模型,剖析显式同步与隐式因果的哲学差异,揭示happens-before等机制如何保障内存可见性与数据一致性,展现两大范式的深层分野。(238字)
129 4
|
4月前
|
缓存 安全 Java
如何理解Java中的并发?
Java并发指多任务交替执行,提升资源利用率与响应速度。通过线程实现,涉及线程安全、可见性、原子性等问题,需用synchronized、volatile、线程池及并发工具类解决,是高并发系统开发的关键基础。(238字)
297 5
|
7月前
|
Java API 调度
从阻塞到畅通:Java虚拟线程开启并发新纪元
从阻塞到畅通:Java虚拟线程开启并发新纪元
400 83
|
10月前
|
消息中间件 算法 安全
JUC并发—1.Java集合包底层源码剖析
本文主要对JDK中的集合包源码进行了剖析。
|
7月前
|
存储 Java 调度
Java虚拟线程:轻量级并发的革命性突破
Java虚拟线程:轻量级并发的革命性突破
426 83
|
9月前
|
机器学习/深度学习 消息中间件 存储
【高薪程序员必看】万字长文拆解Java并发编程!(9-2):并发工具-线程池
🌟 ​大家好,我是摘星!​ 🌟今天为大家带来的是并发编程中的强力并发工具-线程池,废话不多说让我们直接开始。
347 0
|
7月前
|
SQL 缓存 安全
深度理解 Java 内存模型:从并发基石到实践应用
本文深入解析 Java 内存模型(JMM),涵盖其在并发编程中的核心作用与实践应用。内容包括 JMM 解决的可见性、原子性和有序性问题,线程与内存的交互机制,volatile、synchronized 和 happens-before 等关键机制的使用,以及在单例模式、线程通信等场景中的实战案例。同时,还介绍了常见并发 Bug 的排查与解决方案,帮助开发者写出高效、线程安全的 Java 程序。
414 0
|
8月前
|
Java 物联网 数据处理
Java Solon v3.2.0 史上最强性能优化版本发布 并发能力提升 700% 内存占用节省 50%
Java Solon v3.2.0 是一款性能卓越的后端开发框架,新版本并发性能提升700%,内存占用节省50%。本文将从核心特性(如事件驱动模型与内存优化)、技术方案示例(Web应用搭建与数据库集成)到实际应用案例(电商平台与物联网平台)全面解析其优势与使用方法。通过简单代码示例和真实场景展示,帮助开发者快速掌握并应用于项目中,大幅提升系统性能与资源利用率。
237 6
Java Solon v3.2.0 史上最强性能优化版本发布 并发能力提升 700% 内存占用节省 50%
|
9月前
|
缓存 安全 Java
【高薪程序员必看】万字长文拆解Java并发编程!(3-1):并发共享问题的解决与分析
活锁:多个线程相互影响对方退出同步代码块的条件而导致线程一直运行的情况。例如,线程1的退出条件是count=5,而线程2和线程3在其代码块中不断地是count进行自增自减的操作,导致线程1永远运行。内存一致性问题:由于JIT即时编译器对缓存的优化和指令重排等造成的内存可见性和有序性问题,可以通过synchronized,volatile,并发集合类等机制来解决。这里的线程安全是指,多个线程调用它们同一个实例的方法时,是线程安全的,但仅仅能保证当前调用的方法是线程安全的,不同方法之间是线程不安全的。
166 0