java 无锁编程_使用CAS、FAA实现无锁编程

java 无锁编程_使用CAS、FAA实现无锁编程锁会导致性能降低,在特定情况可用硬件同步原语替代锁,保证和锁一样数据安全,同时提供更好性能。硬件同步原语(AtomicHardwarePrimitives)由计算机硬件提供的一组原子操作,较常用的原语主要是CAS和FAA两种。CAS(CompareandSwap)比较交换FAA原语(FetchandAdd)语义是,先获取变量p当前的值value,然后给变量p增加inc,最后返回变量p之…

大家好,又见面了,我是你们的朋友全栈君。

锁会导致性能降低,在特定情况可用硬件同步原语替代锁,保证和锁一样数据安全,同时提供更好性能。

硬件同步原语(Atomic Hardware Primitives)

由计算机硬件提供的一组原子操作,较常用的原语主要是CAS和FAA两种。

CAS(Compare and Swap)比较交换

FAA原语(Fetch and Add)语义是,先获取变量p当前的值value,然后给变量p增加inc,最后返回变量p之前的值value。

原语有什么特殊的呢?

用编程语言来实现,肯定是无法保证原子性的。而原语是由计算机CPU提供实现,可保证操作的原子性。

原子操作具有不可分割性,不存在并发问题。所以在某些情况下,原语可以用来替代锁,实现一些即安全又高效的并发操作。

CAS和FAA在各种编程语言中,都有相应的实现,可直接使用,各种语言底层实现一样的。

注意并不是通过系统调用实现的,系统调用的开销不小,cas本来就是为了提升性能,不会走系统调用。事实上是在用户态直接使用汇编指令就可以实现。

账户服务示例

有个共享变量balance,保存当前账户余额,然后模拟多线程并发转账,看如何使用CAS原语来保证数据的安全性。

锁实现:

package main

import (

“fmt”

“sync”

)

func main() {

// 账户初始值为0元

var balance int32

balance = int32(0)

done := make(chan bool)

// 执行10000次转账,每次转入1元

count := 10000

var lock sync.Mutex

for i := 0; i < count; i++ {

// 这里模拟异步并发转账

go transfer(&balance, 1, done, &lock)

}

// 等待所有转账都完成

for i := 0; i < count; i++ {

}

// 打印账户余额

fmt.Printf(“balance = %d \n”, balance)

}

// 转账服务

func transfer(balance *int32, amount int, done chan bool, lock *sync.Mutex) {

lock.Lock()

*balance = *balance + int32(amount)

lock.Unlock()

done

}

然后启动多协程并发执行10000次转账,每次往账户中转入1元,全部转账执行完成后,账户中的余额应该正好10000。

反复多次执行,每次balance的结果都正好是10000,那安全性没问题。

CAS实现

func transferCas(balance *int32, amount int, done chan bool) {

for {

old := atomic.LoadInt32(balance)

new := old + int32(amount)

if atomic.CompareAndSwapInt32(balance, old, new) {

break

}

}

done

}

首先,for做个没有退出条件的循环。在这个循环内,反复调用CAS尝试给账户余额+1。

CAS前置条件:只有变量balance的值等于old,才会将balance赋为new。

在for循环中执行3条语句,在并发的环境中执行,会有两种可能:

执行到第3条CAS时,没有其他线程同时改变账户余额,那可安全变更账户余额。这时CAS返回值一定true,转账成功,即可退出循环。并且CAS语句,是个原子操作,赋值安全性也可保证。

在这过程,有其他线程改变账户余额,这时是无法保证数据安全的,不能再赋值。执行CAS时,由于无法通过比较步骤,所以不会执行赋值。本次尝试转账失败,当前线程并没有对账户余额做任何变更。由于返回值为false,不会退出循环,所以会继续重试,直到转账成功退循环。

这样每次转账操作,都可通过若干次重试,在保证安全性前提下,完成并发转账。

其实该例还有更简单性能更好方案:

FAA

func transferFaa(balance *int32, amount int, done chan bool) {

atomic.AddInt32(balance, int32(amount))

done

}

java.util.concurrent.atomic.AtomicLong#getAndAdd

FAA原语

获取变量当前值,然后把它做个加法,且保证该操作的原子性,一行代码即可。你开始好奇了,那CAS还有何意义?

该案例肯定FAA更合适,但CAS适用范围更广。

类似逻辑:先读数据,做计算,然后更新数据,无论这个计算啥样,都可用CAS保护数据安全。

但FAA逻辑局限于简单加减法。所以并非说CAS没有意义。

使用CAS反复重试赋值比较耗费CPU,因为for循环如果赋值不成,会立即进入下一次循环,没有等待的。如果线程间碰撞频繁,经常反复重试,这重试的线程会占用大量CPU时间,系统性能就会下降。

缓解这问题的一个方法是使用Yield(), 大部分编程语言都支持Yield()系统调用。

Yield()作用

告诉os,让出当前线程占用的CPU给其他线程。每次循环结束前调用下Yield(),可在一定程度上降低CPU使用率,缓解该问题。也可在每次循环结束后,Sleep()小段时间,但这样性能会严重下降。

所以,这种方法它只适于线程碰撞不太频繁,即执行CAS不需要重试这样的场景。

用锁、CAS和FAA完整实现账户服务

https://github.com/shenyachen/JKSJ/blob/master/study/src/main/java/com/jksj/study/casAndFaa/CASThread.java

https://github.com/xqq1994/algorithm/blob/master/src/main/java/com/test/concurrency/MutxLock.java

https://github.com/xqq1994/algorithm/blob/master/src/main/java/com/test/concurrency/CAS.java

参考

https://time.geekbang.org/column/article/130743

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请联系我们举报,一经查实,本站将立刻删除。

发布者:全栈程序员-站长,转载请注明出处:https://javaforall.net/136694.html原文链接:https://javaforall.net

(0)
全栈程序员-站长的头像全栈程序员-站长


相关推荐

  • mybatis 查询返回List集合、map集合、List<Map>集合[通俗易懂]

    mybatis 查询返回List集合、map集合、List<Map>集合[通俗易懂]主要是加上这一行:resultType=“java.lang.String” <!–查询所有的学生去向–> <selectid=”selectStudentDirection”resultType=”java.lang.String”> SELECTdirectionNamefromwork_direction </select>…

    2022年9月27日
    0
  • eplan激活码大全-激活码分享2022.01.21

    (eplan激活码大全)最近有小伙伴私信我,问我这边有没有免费的intellijIdea的激活码,然后我将全栈君台教程分享给他了。激活成功之后他一直表示感谢,哈哈~IntelliJ2021最新激活注册码,破解教程可免费永久激活,亲测有效,下面是详细链接哦~https://javaforall.net/100143.html…

    2022年3月31日
    253
  • css-day05笔记-清除浮动&学成网布局准备工作

    css-day05笔记-清除浮动&学成网布局准备工作typora-copy-images-to:media第01阶段.WEB基础:css-day05笔记-清除浮动&学成网布局准备工作一.清除浮动1.为什么要清除浮动因为父级盒子很多情况下,不方便给高度,但是子盒子浮动就不占有位置,最后父级盒子高度为0,就影响了后面的标准流盒子。总结:由于浮动元素不再占用原文档流的位置,所以它会对后面的元素排版产生影响准确地说…

    2022年5月28日
    32
  • 设计模式之策略模式_策略模式和状态模式

    设计模式之策略模式_策略模式和状态模式概述在策略模式(StrategyPattern)中,一个类的行为或其算法可以在运行时更改。这种类型的设计模式属于行为型模式。在策略模式中,我们创建表示各种策略的对象和一个行为随着策略对象改变而改

    2022年8月16日
    14
  • 小程序开发组件概述_小程序开发教程

    小程序开发组件概述_小程序开发教程编写组件基本结构接上文:微信小程序开发02-小程序基本介绍我们今天先来实现这个弹出层:之前这个组件是一个容器类组件,弹出层可设置载入的html结构,然后再设置各种事件即可,这种组件有一个特点:

    2022年8月5日
    3
  • Java常见的8种数据结构「建议收藏」

    Java常见的8种数据结构「建议收藏」数据结构是指数据在计算机内存空间中或磁盘中的组织形式算法是完成特定任务的过程二分法查找r=2^ss:查找步数r查找范围幂函数s=log2®已知范围获取需要的次数对数算法复杂度使用O(N)函数进行标示主要是去除常数看运行时间受数据项个数的影响常见排序参考地址https://blog.csdn.net/muranfei/article/details/80923996栈对列优先级对列栈按照“后进先出”、“先进后出”的原则来存储数据,先插入的数…

    2022年7月7日
    20

发表回复

您的邮箱地址不会被公开。 必填项已用 * 标注

关注全栈程序员社区公众号