-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathCasDemo.java
More file actions
48 lines (41 loc) · 1.75 KB
/
Copy pathCasDemo.java
File metadata and controls
48 lines (41 loc) · 1.75 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
package com.concurrent;
/**
*
* CAS（Compare and swap）比较和替换是设计并发算法时用到的一种技术。
* 简单来说，比较和替换是使用一个期望值和一个变量的当前值进行比较，如果当前变量的值与我们期望的值相等，就使用一个新值替换当前变量的值。
* 以下用同步锁synchronized模拟CAS 算法。注意：真正的CAS算法是无锁的。
*/
public class CasDemo {
public static void main(String[] args) {
final CompareAndSwap cas = new CompareAndSwap();
for(int i=0; i<10; i++){
// 创建10个线程,模拟多线程环境
new Thread(new Runnable(){
@Override
public void run(){
int expectedValue = cas.get();
boolean b = cas.compareAndSwap(expectedValue, (int)(Math.random()*5));
}
}).start();
}
}
static class CompareAndSwap{
private int value;
// 获取内存值
public synchronized int get() {
return value;
}
// 比较当前值和期望值,相同就替换。
public synchronized boolean compareAndSwap(int expectedValue,int newValue) {
//获取旧值
int oldValue=value;
if(oldValue==expectedValue) {
this.value=newValue;
System.out.println(Thread.currentThread().getName()+"比较当前值和期望值，结果一致，将其替换为新值。");
return true;
}
System.out.println(Thread.currentThread().getName()+"比较当前值和期望值，结果不一致，不替换为新值");
return false;
}
}
}