Java无锁并发工具类Unsafe.compareAndSwapLong方法

news/2024/7/24 8:36:49 标签: java, 开发语言, jvm

compareAndSwapLong方法是一个原子操作,通常用于并发编程中的无锁算法。它的作用是以原子方式比较并交换某个对象的一个long类型的字段。具体来说,它接收4个参数:

  1. Object obj: 需要操作的对象。
  2. long offsetobj中要操作的字段的内存偏移量。
  3. long expected: 预期的值,用于比较。
  4. long updated: 要更新的值。

compareAndSwapLong方法首先会比较obj中偏移量为offset的字段的当前值与expected是否相等。如果相等,说明没有其他线程修改过这个字段的值,那么方法会将该字段更新为updated值,并返回true。如果不相等,说明其他线程可能已经修改过这个字段的值,那么方法不做任何操作,并返回false

这个方法通常与Unsafe类一起使用,这是一个用于执行低级操作的类。它允许你直接操作Java对象的内存,包括获取和设置字段的值、分配和释放内存等。compareAndSwapLong方法通常用于实现高性能的并发数据结构,如AtomicLongConcurrentHashMap等。

java">import sun.misc.Unsafe;

import java.lang.reflect.Field;

public class CompareAndSwapLongExample {
    private static Unsafe unsafe;
    private static long valueOffset;
    private long value;

    static {
        try {
            // 获取Unsafe实例
            Field unsafeField = Unsafe.class.getDeclaredField("theUnsafe");
            unsafeField.setAccessible(true);
            unsafe = (Unsafe) unsafeField.get(null);

            // 获取value字段的内存偏移量
            valueOffset = unsafe.objectFieldOffset(CompareAndSwapLongExample.class.getDeclaredField("value"));
        } catch (NoSuchFieldException | IllegalAccessException e) {
            e.printStackTrace();
        }
    }

    public boolean compareAndSet(long expected, long updated) {
        return unsafe.compareAndSwapLong(this, valueOffset, expected, updated);
    }

    public void increment() {
        long oldValue;
        long newValue;
        do {
            oldValue = value;
            newValue = oldValue + 1;
        } while (!compareAndSet(oldValue, newValue));
    }

    public static void main(String[] args) {
        CompareAndSwapLongExample example = new CompareAndSwapLongExample();
        for (int i = 0; i < 5; i++) {
            example.increment();
            System.out.println("Value: " + example.value);
        }
    }
}


http://www.niftyadmin.cn/n/4990493.html

相关文章

C++ Qt QModbusClient 的使用

在C Qt中使用QModbusClient进行Modbus通信&#xff0c;您可以按照以下步骤进行操作&#xff1a; 包含必要的头文件&#xff1a; #include <QModbusClient> #include <QModbusDataUnit> #include <QModbusTcpClient> // 如果使用TCP连接 #include <QModb…

【Sword系列】Vulnhub靶机HACKADEMIC: RTB1 writeup

靶机介绍 官方下载地址&#xff1a;https://www.vulnhub.com/entry/hackademic-rtb1,17/ 需要读取靶机的root目录下key.txt 运行环境&#xff1a; 虚拟机网络设置的是NAT模式 靶机&#xff1a;IP地址&#xff1a;192.168.233.131 攻击机&#xff1a;kali linux&#xff0c;IP地…

政企局域网办公首选:WorkPlus专为政企打造的IM即时通讯平台

政府机构与企业在信息交流与协作中的安全高效需求&#xff0c;使得私有化部署的IM即时通讯平台成为必要选择。WorkPlus提供符合客户应用场景的数字化平台解决方案&#xff0c;满足政企局域网办公需求。WorkPlus如何为政企提供定制化的IM即时通讯解决方案&#xff0c;助力政企机…

selenium中定位shadow-root,以及获取shadow-root内部的数据

通过shadow-root的父级定位到shadow-root,再通过语句进行操作 两种方法&#xff1a; 第一种&#xff0c;Python种JS实现 第二种&#xff0c;selenium实现 1.0 案例网站 参考某橘色网站 2.0 js语句定位 可在控制台进行测试 测试语句 document.querySelector("ali-ba…

Web3 社交平台如何脱颖而出?我们和 PoPP 聊了聊

能够颠覆 Web2 传统模式的社交产品有着怎样的特征&#xff1f;PoPP 作为专注于 Web3 的私域流量变现平台&#xff0c;为开发者和用户提供了社交产品发展的新路径&#xff0c;让社区用户充分实现互动交流&#xff0c;着力于创作内容的激励与变现。事实上&#xff0c;面对 Web3 社…

java八股文面试[多线程]——一个线程两次调用start()方法会出现什么情况

典型回答&#xff1a; Java 的线程是不允许启动两次的&#xff0c;第二次调用必然会抛出 IllegalThreadStateException&#xff0c;这是一种运行时异常&#xff0c;多次调用 start 被认为是编程错误。 通过线程的状态图&#xff0c;在第二次调用 start() 方法的时候&#xff…

扎根嵌入式行业需要什么学历文凭?

在嵌入式行业&#xff0c;学历并不是唯一关键。我本人拥有电子工程学士学位&#xff0c;但嵌入式行业更看重实际技能和经验。视频后方有免费的嵌入式学习资料&#xff0c;入门和进阶内容都涵盖其中。嵌入式行业一般接纳各种学历&#xff0c;从专科到本科到研究生&#xff0c;甚…

2023开学季图书馆荐八一新书《乡村振兴战略下传统村落文化旅游设计 》中大许少辉博士后著

2023开学季图书馆荐八一新书《乡村振兴战略下传统村落文化旅游设计 》中大许少辉博士后著