【CAP】JAVA之AtomicReference非锁同步

并发最简单的竞态问题是操作一个基本变量,如一个整数。

复杂问题是同时操作多个变量,要保证变量的结果一致,比如A加1那B就要减1。

简单问题和复杂问题都可以通过锁来实现。

用锁划出临界区(一段代码),这段代码通过锁保证不能被并行执行。

代码就是对竞态数据的逻辑操作,并且只能通过这段代码操作竞态数据。

CAS提供了另一种解决竞态问题的方案。

AtomicReference解决竞态问题

比如A加1那B就要减1的问题,可以把A和B做成一个对象。

1
AtomicReference<AB> data = new AtomicReference<AB>();

每个线程复制一份data,操作完后通过compareAndSet设置到公共变量。

可以参考AtomicInteger加1的操作:

1
2
3
4
5
6
7
8
public final int incrementAndGet() {
for (;;) {
int current = get();
int next = current + 1;
if (compareAndSet(current, next))
return next;
}
}

可以封装个AtomicAB类来完成这件事,复制data到ThreadLocal中,修改完后再写加公共data对象。