本节主要讲解Atomic打头的原子类的使用和原理。
原子操作是指不会被线程调度机制打断的操作,这种操作一旦开始,就一直运行到结束,中间不会有任何线程上下文切换。
原子操作可以是一个步骤,也可以是多个操作步骤,但是其顺序不可以被打乱,也不可以被切割而只执行其中的一部分,将整个操作视作一个整体是原子性的核心特征。
在java中提供了很多原子类,主要把这些原子类分成四大类。
原子更新布尔类型,内部使用int类型的value存储1和0表示true和false,底层也是对int类型的原子操作。
原子更新int类型。
原子更新long类型。
原子更新引用类型,通过泛型指定要操作的类。
原子更新引用类型,内部使用Pair承载引用对象及是否被更新过的标记,避免了ABA问题。
原子更新引用类型,内部使用Pair承载引用对象及更新的邮戳,避免了ABA问题。
原子更新数组中的元素,可以更新数组中指定索引位置的元素,这些类主要有:
原子更新int数组中的元素。
原子更新long数组中的元素。
原子更新Object数组中的元素。
原子更新对象中的字段,可以更新对象中指定字段名称的字段,这些类主要有:
原子更新对象中的int类型字段。
原子更新对象中的long类型字段。
原子更新对象中的引用类型字段。
高性能原子类,是java8中增加的原子类,它们使用分段的思想,把不同的线程hash到不同的段上去更新,最后再把这些段的值相加得到最终的值,这些类主要有:
下面四个类的父类。
long类型的聚合器,需要传入一个long类型的二元操作,可以用来计算各种聚合操作,包括加乘等。
long类型的累加器,LongAccumulator的特例,只能用来计算加法,且从0开始计算。
double类型的聚合器,需要传入一个double类型的二元操作,可以用来计算各种聚合操作,包括加乘等。
double类型的累加器,DoubleAccumulator的特例,只能用来计算加法,且从0开始计算。
package com.example.atomic.atomicinteger.demo;
import java.util.concurrent.atomic.AtomicInteger;
/**
* @Author: 无双老师【云析学院:http://yunxiedu.net QQ:3190976240 email:zhouguanya20@163.com】
* @Date: 2020-03-21 16:20
* @Description: AtomicInteger使用方式
*/
public class AtomicIntegerDemo {
public static void main(String[] args) throws InterruptedException {
test1();
test2();
}
private static void test1() throws InterruptedException {
Counter counter = new Counter();
// 100个线程
for (int i = 0; i < 10; i++) {
// 每个线程对count累加10次
new Thread(() -> {
for (int j = 0; j < 1000; j++) {
counter.addCount();
}
}).start();
}
Thread.sleep(1000);
System.out.println("count = " + counter.getCount());
}
private static void test2() throws InterruptedException {
/**
* 原子性的int
*/
AtomicInteger count = new AtomicInteger();
// 100个线程
for (int i = 0; i < 10; i++) {
// 每个线程对count累加10次
new Thread(() -> {
for (int j = 0; j < 1000; j++) {
count.incrementAndGet();
}
}).start();
}
Thread.sleep(1000);
System.out.println("count = " + count.get());
}
}
/**
* volatile修饰的计数器
*/
private volatile static int count = 0;
public void addCount() {
count++;
}
public int getCount() {
return count;
}
public class AtomicInteger extends Number implements java.io.Serializable
// setup to use Unsafe.compareAndSwapInt for updates
private static final Unsafe unsafe = Unsafe.getUnsafe();
private static final long valueOffset;
static {
try {
valueOffset = unsafe.objectFieldOffset
(AtomicInteger.class.getDeclaredField("value"));
} catch (Exception ex) { throw new Error(ex); }
}
private volatile int value;
/**
* Creates a new AtomicInteger with the given initial value.
*
* @param initialValue the initial value
*/
public AtomicInteger(int initialValue) {
value = initialValue;
}
/**
* Creates a new AtomicInteger with initial value {@code 0}.
*/
public AtomicInteger() {
}
/**
* Atomically increments by one the current value.
*
* @return the updated value
*/
public final int incrementAndGet() {
return unsafe.getAndAddInt(this, valueOffset, 1) + 1;
}
调用Unsafe类的方法如下。
public final int getAndAddInt(Object var1, long var2, int var4) {
int var5;
do {
var5 = this.getIntVolatile(var1, var2);
} while(!this.compareAndSwapInt(var1, var2, var5, var5 + var4));
return var5;
}
注意观察compareAndSwapInt即CAS方式修改int值。
AtomicInteger.incrementAndGet方法自增的原理: