【并发技术09】原子性操作类的使用-伙伴云

【并发技术09】原子性操作类的使用

网友投稿 608 2022-05-30

方法，其中包含：

1. 基本类型的使用

首先看一下 AtomicInteger 的使用，AtomicInteger 主要是针对整数的修改的，看一下示例代码：

public class AtomicIntegerDemo {

public final static AtomicInteger TEST_INTEGER = new AtomicInteger(1);

public static void main(String []args) {

for(int i = 0 ; i < 10 ; i++) { //开启10个线程

new Thread() {

public void run() {

try {

Thread.sleep(1000);

} catch (InterruptedException e) {

e.printStackTrace();

}

int now = TEST_INTEGER.incrementAndGet(); //自增

System.out.println(Thread.currentThread().getName() + " get value : " + now);

}

}.start();

}

来看一下结果：

Thread-3 get value : 4

Thread-7 get value : 5

Thread-9 get value : 9

Thread-4 get value : 6

Thread-0 get value : 3

Thread-1 get value : 8

Thread-5 get value : 11

Thread-8 get value : 7

Thread-2 get value : 10

Thread-6 get value : 2

可以看出，10 个线程之间是线程安全的，并没有冲突。也就是说，我们使用原子性操作类去操作基本类型 int 就可以解决线程安全问题，一个线程在操作的时候，会对其它线程进行排斥，不用我们手动去使用 synchronized 实现互斥操作了。AtomicLong 和 AtomicBoolean 类似，就不举例子了。

2. 数组类型的使用

下面要开始说 Atomic 的数组用法，Atomic 的数组要求不允许修改长度等，不像集合类那么丰富的操作，不过它可以让数组上每个元素的操作绝对安全的，也就是它细化的力度还是到数组上的元素，做了二次包装，虽然是数组类型的，但是最后还是操作数组中存的数，所以会了上面的基本类型的话，数组类型也很好理解。这里主要看一下 AtomicIntegerArray 的使用，其它的类似。

public class AtomicIntegerArrayTest {

private final static AtomicIntegerArray ATOMIC_INTEGER_ARRAY = new AtomicIntegerArray(new int[]{1,2,3,4,5,6,7,8,9,10});

public static void main(String []args) throws InterruptedException {

Thread []threads = new Thread[10];

for(int i = 0 ; i < 10 ; i++) {

final int index = i;

final int threadNum = i;

threads[i] = new Thread() {

public void run() {

int result = ATOMIC_INTEGER_ARRAY.addAndGet(index, index + 1);

System.out.println("线程编号为：" + threadNum + " , 对应的原始值为：" + (index + 1) + "，增加后的结果为：" + result);

}