【实战Java高并发程序设计 4】数组也能无锁:AtomicIntegerArray

除了提供基本数据类型外,JDK还为我们准备了数组等复合结构。当前可用的原子数组有:AtomicIntegerArray、AtomicLongArray和AtomicReferenceArray,分别表示整数数组、long型数组和普通的对象数组。

这里以AtomicIntegerArray为例,展示原子数组的使用方式。

AtomicIntegerArray本质上是对int[]类型的封装。使用Unsafe类通过CAS的方式控制int[]在多线程下的安全性。它提供了以下几个核心API:
//获得数组第i个下标的元素
public final int get(int i)
//获得数组的长度
public final int length()
//将数组第i个下标设置为newValue,并返回旧的值
public final int getAndSet(int i, int newValue)
//进行CAS操作,如果第i个下标的元素等于expect,则设置为update,设置成功返回true
public final boolean compareAndSet(int i, int expect, intupdate)
//将第i个下标的元素加1
public final int getAndIncrement(int i)
//将第i个下标的元素减1
public final int getAndDecrement(int i)
//将第i个下标的元素增加delta(delta可以是负数)
public final int getAndAdd(int i, int delta)  

下面给出一个简单的示例,展示AtomicIntegerArray使用:

01 public class AtomicIntegerArrayDemo {
02    staticAtomicIntegerArray arr = new AtomicIntegerArray(10);
03     public staticclass AddThread implements Runnable{
04         publicvoid run(){
05            for(intk=0;k<10000;k++)
06                 arr.getAndIncrement(k%arr.length());
07         }
08     }
09    public staticvoid main(String[] args) throws InterruptedException {
10         Thread[]ts=new Thread[10];
11         for(intk=0;k<10;k++){
12            ts[k]=new Thread(new AddThread());
13         }
14         for(intk=0;k<10;k++){ts[k].start();}
15         for(intk=0;k<10;k++){ts[k].join();}
16         System.out.println(arr);
17    }
18 }  

上述代码第2行,申明了一个内含10个元素的数组。第3行定义的线程对数组内10个元素进行累加操作,每个元素各加1000次。第11行,开启10个这样的线程。因此,可以预测,如果线程安全,数组内10个元素的值必然都是10000。反之,如果线程不安全,则部分或者全部数值会小于10000。

程序的输出结果如下:

  1. [10000, 10000, 10000, 10000, 10000, 10000, 10000, 10000,10000, 10000]

这说明AtomicIntegerArray确实合理地保证了数组的线程安全性。

摘自:实战Java高并发程序设计

时间: 2024-10-30 13:06:17

【实战Java高并发程序设计 4】数组也能无锁:AtomicIntegerArray的相关文章

【实战Java高并发程序设计 5】让普通变量也享受原子操作

[实战Java高并发程序设计 1]Java中的指针:Unsafe类 [实战Java高并发程序设计 2]无锁的对象引用:AtomicReference [实战Java高并发程序设计 3]带有时间戳的对象引用:AtomicStampedReference [实战Java高并发程序设计 4]数组也能无锁:AtomicIntegerArray 有时候,由于初期考虑不周,或者后期的需求变化,一些普通变量可能也会有线程安全的需求.如果改动不大,我们可以简单地修改程序中每一个使用或者读取这个变量的地方.但显然

【实战Java高并发程序设计 7】让线程之间互相帮助--SynchronousQueue的实现

[实战Java高并发程序设计 1]Java中的指针:Unsafe类 [实战Java高并发程序设计 2]无锁的对象引用:AtomicReference [实战Java高并发程序设计 3]带有时间戳的对象引用:AtomicStampedReference [实战Java高并发程序设计 4]数组也能无锁:AtomicIntegerArray [实战Java高并发程序设计 5]让普通变量也享受原子操作 [实战Java高并发程序设计6]挑战无锁算法:无锁的Vector实现 在对线程池的介绍中,提到了一个非

【实战Java高并发程序设计 3】带有时间戳的对象引用:AtomicStampedReference

[实战Java高并发程序设计 1]Java中的指针:Unsafe类 [实战Java高并发程序设计 2]无锁的对象引用:AtomicReference AtomicReference无法解决上述问题的根本是因为对象在修改过程中,丢失了状态信息.对象值本身与状态被画上了等号.因此,我们只要能够记录对象在修改过程中的状态值,就可以很好的解决对象被反复修改导致线程无法正确判断对象状态的问题. AtomicStampedReference正是这么做的.它内部不仅维护了对象值,还维护了一个时间戳(我这里把它

我的《实战java高并发程序设计》纸质书上市了

在过去单核CPU时代,单任务在一个时间点只能执行单一程序,随着多核CPU的发展,并行程序开发就显得尤为重要. <实战Java高并发程序设计>主要介绍基于Java的并行程序设计基础.思路.方法和实战.首先,立足于并发程序基础,详细介绍Java中进行并行程序设计的基本方法.第二,进一步详细介绍JDK中对并行程序的强大支持,帮助读者快速.稳健地进行并行程序开发.第三,详细讨论有关"锁"的优化和提高并行程序性能级别的方法和思路.第四,介绍并行的基本设计模式及Java8对并行程序的支

【实战Java高并发程序设计 1】Java中的指针:Unsafe类

是<实战Java高并发程序设计>第4章的几点. 如果你对技术有着不折不挠的追求,应该还会特别在意incrementAndGet() 方法中compareAndSet()的实现.现在,就让我们更进一步看一下它把! public final boolean compareAndSet(int expect, int update){ returnunsafe.compareAndSwapInt(this, valueOffset, expect, update); } 在这里,我们看到一个特殊的变

实战java高并发程序设计 1

重要概念 同步(synchronous)和异步(asynchronous) 同步等待方法返回 异步瞬间返回,继续下一次调用 并发(Concurrency)和并行(Parallelism) 并发与并行外界表现一致 单核心cpu无法并行,但可以处理并行事务 临界区 公共资源或者共享数据 多线程访问时,可能造成临界区数据破坏 阻塞(Blocking)和非阻塞(Non-Blocking) 非阻塞允许多个线程同时进入临界区 死锁(Deadlock).饥饿(Starvation)和活锁(Livelock)

一图搞定【实战Java高并发程序设计】

来了解下java并发的技术点吧.

Java高并发程序设计

一.并行世界 摩尔定律的失效,2004年秋季,Intel宣布彻底取消4GHz计划,CPU向多核心的发展,顶级计算机科学家唐纳德丶尔文丶克努斯评价:在我看来,这种现象(并发)或多或少是由于硬件设计者已经无计可施导致的,他们将摩尔定律失效的责任推脱给软件开发者. 1.几个概念 同步和异步: 并发与并行:都表示多个任务同时执行,但并发偏重于多个任务交替执行. 临界区:即共享的数据 阻塞和非阻塞: 死锁.饥饿和活锁:死锁为互不让行,饥饿为一直拿不到资源,活锁为一直撞到 2.并发级别   由于临界区的存在

Java高并发程序设计(十)--无锁

锁是一种悲观策略,总是觉得会出问题,所以小心翼翼地操作. 无锁是一种乐观策略,总是假设不会出现问题,如果出现问题,那就重新操作.无锁一般使用CAS作为策略. 比较交换CAS: CAS算法包括三个参数:需要更新的变量,预期值,更新值.只有当需要更新的值等于预期值时,说明其他线程没有对它进行操作,使需要更新值等于更新值. 在java.util.concurrent.atomic中,实现了很多无锁的类型: 用AtomicInteger写个小例子: public class demo implement