2.原子变量 CAS算法

前面提到,使用volatile无法保证 变量状态的原子性操作,所谓原子性,就是不可再分

  如:i++的原子性问题,i++ 的操作实际上分为三个步骤  "读-改-写"

  (1)保存i的值(一个临时变量中)

  (2)递增i

  (3)返回已保存的值

当在并发的条件下执行 i++,

线程1执行 i++,先从主存中 获取 i 的 值(假设初值i=0),还未等 执行i = i + 1,此时线程2进来,也从主存中获取 i 的 值(0)

然后 线程1 执行了 i = i + 1;(i=1) 线程2再执行 i = i + 1(i=1),这种结果是错误的

即使使用 volatile ,保证内存的可见性,也是不管用的,即使在主存中进行修改操作,一样会产生这种错误

此时,可以采用 CAS算法 ,CAS算法 是 乐观锁的一种(冲突检测)(hibernate 的乐观锁是 加一个 version 字段,来判断是否发生了并发)

CAS(Compare-And-Swap) 算法 保证数据变量的原子性

CAS 算法是硬件对于并发操作的支持

CAS 包含了三个操作数:

  * ①内存值 V

  * ②预估值 A

  * ③更新值 B

* 当且仅当 V == A 时, V = B; 否则,不会执行任何操作。

过程分析:同样在 并发条件下 执行 i++

  1、线程1 执行 i++,先从主存中获取 i 的值(V=i=0) (设i=0),此时线程2进来,也从主存中 获取 i 的 值(0)

  2、然后线程1 执行 getAndIncrement,即比较和替换一起执行,(过程:再从内存中读取一遍i的值(A=i=0),让 A(0) 与 V(0)进行比较,

发现 V==A,此时,B = i+1,将B的值更新到内存中(V = B) )

  3、然后 线程2 开始执行 getAndIncrement,即比较和替换一起执行,过程 和 上述类似,不过再从内存读一次值,i的值已经变成了 1 ,即A的值也为1

让A(1)与V(0)进行比较比较,发现 V!=A, 不执行任何操作

注:将 V 与 A 比较的意义在于 判断 要更新的值(V)是否发生了改变,如果没有发生改变,则进行 V 的 更新,否则不做任何操作

再发现 V!=A 后,与 synchronize 不一样的 是,这里不会发生阻塞,不会等当前线程执行完后,再由CPU 分配时间去给线程2去执行,

而是不停的 循环发送请求,紧接着再去尝试,再去更新,这也是 CAS算法 比普通同步锁的做法 效率要高的原因

采用CAS算法之后,当有多个线程访问 内存中的共享资源,一次只会有一个线程成功,其他线程都会失败

java.util.concurrent.atomic 包下提供了一些原子操作的常用类:里面频繁的使用到了CAS算法来保证变量状态的原子性操作

  ? AtomicBoolean 、 AtomicInteger 、 AtomicLong 、 AtomicReference

  ? AtomicIntegerArray 、 AtomicLongArray

  ? AtomicMarkableReference

  ? AtomicReferenceArray

  ? AtomicStampedReference

l核心方法:boolean compareAndSet(expectedValue, updateValue)  (也是CAS里面的核心,即比较和替换一起执行)

 1 /*
 2  * 一、i++ 的原子性问题:i++ 的操作实际上分为三个步骤“读-改-写”
 3  *           int i = 10;
 4  *           i = i++; //10
 5  *
 6  *           (1)保存i的值(一个临时变量中)
 7           (2)递增i
 8           (3)返回已保存的值
 9  *
10  * 二、原子变量:在 java.util.concurrent.atomic 包下提供了一些原子变量。
11  *         1. volatile 保证内存可见性
12  *         2. CAS(Compare-And-Swap) 算法保证数据变量的原子性
13  *             CAS 算法是硬件对于并发操作的支持
14  *             CAS 包含了三个操作数:
15  *             ①内存值  V
16  *             ②预估值  A
17  *             ③更新值  B
18  *             当且仅当 V == A 时, V = B; 否则,不会执行任何操作。
19  */
20
21 public class TestAtomic {
22     public static void main(String[] args) {
23
24         AtomicDemo ad = new AtomicDemo();
25         for(int i = 0;i<10;i++) {
26             new Thread(ad).start();
27         }
28     }
29 }
30
31 class AtomicDemo implements Runnable {
32     //创建原子变量
33     private AtomicInteger i = new AtomicInteger(0);
34     @Override
35     public void run() {
36         try {
37             Thread.sleep(200);
38         } catch (InterruptedException e) {
39
40         }
41         //查看源码可以发现 循环一直调用compareAndSet(ExceptionValue,UpdateValue)方法,即比较和替换一起执行,
42         //并且如果失败了,会不停的去尝试更新(里面使用到CAS算法的)
43         System.out.println(i.getAndIncrement());
44     }
45
46
47 }
时间: 2024-10-06 16:14:11

2.原子变量 CAS算法的相关文章

原子变量与CAS算法

上一节讨论了 volatile关键字,volatile关键字修饰的作用是不具有 "原子性" 和 "互斥性的" 例如 i++ 操作 就不是一个原子性的操作,i++ 其实分为3个步骤进行 "读-改-写" int temp = i; i = i + 1; i= temp; 先看一段代码: package com.java.juc; public class TestAtomicDemo { public static void main(String[

三、原子变量与CAS算法

原子变量:jdk1.5 后 java.util.concurrent.atomic 包下提供了常用的原子变量: - AtomicBoolean - AtomicInteger - AtomicLong - AtomicReference - AtomicIntegerArray - AtomicLongArray - AtomicMarkableReference - AtomicReferenceArray - AtomicStampedReference 1.以上类中的变量都是volatil

volatile关键字与内存可见性&amp;原子变量与CAS算法

1 .volatile 关键字:当多个线程进行操作共享数据时, 可以保证内存中的数据可见 2 .原子变量:jdk1.5后java.util.concurrent.atomic 包下提供常用的原子变量 3 .模拟CAS算法 TestVolatile package com.aff.juc; /* 1.volatile 关键字:当多个线程进行操作共享数据时, 可以保证内存中的数据可见 相较于synchronized是一种较为轻量级的同步策略 注意: volatile不具备"互斥性" 不能保

原子变量和CAS算法以及ConcurrentHashMap

1.首先做一个测试:i++.输出结果为10,因为在底层实现的时候会引入一个临时变量具体为: 1 public static void main(String[] args) { 2 //i++测试: 3 int i=10; 4 i=i++; 5 System.out.println(i); 6 /* 7 *底层原理: 8 _temp = i ; 9 i = i + 1 ; 10 i = _temp ; 11 * */ 12 } 所以i++就是一个非原子性操作,采用多线程再次测试:测试结果中会因为

Java并发——原子变量和原子操作与阻塞算法

十五年前,多处理器系统是高度专用系统,要花费数十万美元(大多数具有两个到四个处理器).现在,多处理器系统很便宜,而且数量很多,几乎每个主要微处理器都内置了多处理支持,其中许多系统支持数十个或数百个处理器. 要使用多处理器系统的功能,通常需要使用多线程构造应用程序.但是正如任何编写并发应用程序的人可以告诉你的那样,要获得好的硬件利用率,只是简单地在多个线程中分割工作是不够的,还必须确保线程确实大部分时间都在工作,而不是在等待更多的工作,或等待锁定共享数据结构. 问题:线程之间的协调 如果线程之间 

并发策略-CAS算法

对于并发控制而言,我们平时用的锁(synchronized,Lock)是一种悲观的策略.它总是假设每一次临界区操作会产生冲突,因此,必须对每次操作都小心翼翼.如果多个线程同时访问临界区资源,就宁可牺牲性能让线程进行等待,所以锁会阻塞线程执行. 与之相对的有一种乐观的策略,它会假设对资源的访问是没有冲突的.既然没有冲突也就无需等待了,所有的线程都在不停顿的状态下持续执行.那如果遇到问题了无锁的策略使用一种叫做比较交换(CAS Compare And Swap)来鉴别线程冲突,一旦检测到冲突产生,就

Java并发编程实战 第15章 原子变量和非阻塞同步机制

非阻塞的同步机制 简单的说,那就是又要实现同步,又不使用锁. 与基于锁的方案相比,非阻塞算法的实现要麻烦的多,但是它的可伸缩性和活跃性上拥有巨大的优势. 实现非阻塞算法的常见方法就是使用volatile语义和原子变量. 硬件对并发的支持 原子变量的产生主要是处理器的支持,最重要的是大多数处理器架构都支持的CAS(比较并交换)指令. 模拟实现AtomicInteger的++操作 首先我们模拟处理器的CAS语法,之所以说模拟,是因为CAS在处理器中是原子操作直接支持的.不需要加锁. public s

《Java并发编程实战》第十五章 原子变量与非阻塞同步机制 读书笔记

一.锁的劣势 锁定后如果未释放,再次请求锁时会造成阻塞,多线程调度通常遇到阻塞会进行上下文切换,造成更多的开销. 在挂起与恢复线程等过程中存在着很大的开销,并且通常存在着较长时间的中断. 锁可能导致优先级反转,即使较高优先级的线程可以抢先执行,但仍然需要等待锁被释放,从而导致它的优先级会降至低优先级线程的级别. 二.硬件对并发的支持 处理器填写了一些特殊指令,例如:比较并交换.关联加载/条件存储. 1 比较并交换 CAS的含义是:"我认为V的值应该为A,如果是,那么将V的值更新为B,否则不需要修

Java并发——原子变量和原子操作

很多情况下我们只是需要一个简单的.高效的.线程安全的递增递减方案.注意,这里有三个条件:简单,意味着程序员尽可能少的操作底层或者实现起来要比较容易:高效意味着耗用资源要少,程序处理速度要快:线程安全也非常重要,这个在多线程下能保证数据的正确性.这三个条件看起来比较简单,但是实现起来却难以令人满意. 通常情况下,在Java里面,++i或者--i不是线程安全的,这里面有三个独立的操作:获得变量当前值,为该值+1/-1,然后写回新的值.在没有额外资源可以利用的情况下,只能使用加锁才能保证读-改-写这三