• volatile 系列之实现原理


            我们通过volatile解决了由于编译器的指令重排序导致的可见性问题,这意味着volatile 底层用到了内存屏障,下面我们从它的部分源码中找一下内存屏障相关的痕迹。
    通过javap-V VolatileExample.class打印VolatileExample类的字节指令如下。

    1. public static volatile boolean stop;
    2. descriptor: z
    3. flags:ACC_PUBLIC,ACC_STATIC,ACC_VOLATILE


            我们可以看到修饰了volatile关键字的属性,多了一个ACC_VOLATILE的flag。这个指令会通过字节码解释器来执行,定位到Hotspot源码的bytecodeInterpreter.cpp文件,找到_putstatic 指令的解析代码。
            静态变量的获取和赋值分别通过getstatic和putstatic指令来实现,非静态变量通过getfield 和 putfield 指令来操作stop字段代码如下:

    1. CASE(_putstatic):
    2. //省略部分代码
    3. int field_offset = cache->f2_as_index();
    4. if (cache->is_volatile()) {
    5. if (tos_type == itos) {
    6. obj->release_int_field_put(field_offset,STACK_INT(-1));
    7. } else if (tos_type -= atos){
    8. VERIFY_OOP(STACK_OBJECT(-1));
    9. obj->release_obj_field_put(field_offset,STACK_OBJECT(-1));
    10. OrderAccess::release_store(&BYTE_MAP_BASE[(uintptr_t)obj >> CardTableModRefBS::card_shift],0);
    11. }
    12. //省略部分代码
    13. OrderAccess::storeload();
    14. //省略部分代码
    15. }

    上面代码表示,如果当前字段采用volatile 修饰,即 cache->is_volatile(),则根据当前字段类型调用不同的方法进行赋值。

    bool is_volatile    () const    { return (_flags & JVM_ACC_VOLATILE)!=0;}    
    

            在完成stop字段的赋值之后,代码调用了OrderAccess::storeload()内存屏障方法,会基于lock指令来实现内存屏障。
            回到某篇文章中演示VolatileExample可见性问题的代码。

    1. public class VolatileExample {
    2. public volatile static boolean stop=false;
    3. public static void main(String[] args) throws InterruptedException {
    4. Thread t1=new Thread(()->{
    5. int i=0;
    6. while(!stop){ //此时t1 线程来加载stop的值,由于当前CPU的缓存行stop已经失效,
    7. 所以从main线程的缓存行加载或者直接从内存中加载。
    8. i++;
    9. });
    10. t1.start();
    11. System.out.println("begin start thread" );
    12. Thread.sleep(1000); stop=true;
    13. //StoreLoad();//相当于在这里增加了一个内存屏障,该屏障把stop刷新到缓存行
    14. }
    15. }

    上述代码中,对stop增加了volatile关键字之后能够保证可见性的原因是:

    • volatile关键字会在JVM层面声明一个C++的volatile,它能够防止JIT层面的指令重排序。
    • 在对修饰了 volatile关键字的stop字段赋值后,JVM会调用storeload()内存屏障方法,该方法中声明了lock指令,该指令有两个作用。

            在CPU层面,给stop赋值的指令会先存储到Store Buffers中,所以lock 指令会使得Store Buffers 中的数据刷新到缓存行。

            使得其他CPU 中缓存了stop 的缓存行失效,也就是让存储在Invalidate Queues 中的对 stop 失效的指令立即生效。


            当其他线程再去读取stop 的值时,会从内存中或者其他缓存了stop字段的缓存行中重新加载,使得线程能够获得 stop 的最新的值。

  • 相关阅读:
    从零到一建设数据中台 - 数据可视化
    短视频解析易语言代码
    GSEA -- 学习记录
    Spring Cloud Feign 微服务调用组件学习总结
    面试官:我们简单聊一下kafka的一些东西吧。
    台达PLC和昆仑通态触摸屏通讯设置
    解析MySQL数据库:“SQL优化”与“索引优化”
    Redis-核心数据结构
    顾往前行,我的前端之路系列(三)
    pycharm运行后不出结果
  • 原文地址:https://blog.csdn.net/wm31898/article/details/124436491