java中的int类型的java int 线程安全全,AtomicInteger和violate

【实战Java高并发程序设计 4】数组也能无锁:AtomicIntegerArray
& &&【实战Java高并发程序设计 1】Java中的指针:Unsafe类【实战Java高并发程序设计 2】无锁的对象引用:AtomicReference【实战Java高并发程序设计 3】带有时间戳的对象引用:AtomicStampedReference& &除了提供基本数据类型外,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,设置成功返回truepublic final boolean compareAndSet(int i, int expect, intupdate)//将第i个下标的元素加1public final int getAndIncrement(int i)//将第i个下标的元素减1public 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, 1, 1, 1,1]这说明AtomicIntegerArray确实合理地保证了数组的线程安全性。摘自:实战Java高并发程序设计【实战Java高并发程序设计 1】Java中的指针:Unsafe类【实战Java高并发程序设计 2】无锁的对象引用:AtomicReference【实战Java高并发程序设计 3】带有时间戳的对象引用:AtomicStampedReference
分享给朋友:
您可能感兴趣的文章:
随机阅读:本帖子已过去太久远了,不再提供回复功能。用户名:lizhuquan0769
文章数:36
访问量:8677
注册日期:
阅读量:1297
阅读量:3317
阅读量:439594
阅读量:1126324
51CTO推荐博文
&&&&AtomicInteger,一个提供原子操作的Integer的类。在Java语言中,++i和i++操作并不是线程安全的,在使用的时候,不可避免的会用到synchronized关键字。而AtomicInteger则通过一种线程安全的加减操作接口。&&& java.util.concurrent.atomic.AtomicInteger类, 属于java的concurrent包&&&&类方法如下:/**
&&&&来看AtomicInteger提供的接口。&
&//获取当前的值
&public&final&int&get()
&//取当前的值,并设置新的值
&public&final&int&getAndSet(int&newValue)
&//获取当前的值,并自增
&public&final&int&getAndIncrement()&
&//获取当前的值,并自减
&public&final&int&getAndDecrement()
&//获取当前的值,并加上预期的值
&public&final&int&getAndAdd(int&delta)
&//比较值,&符合expect条件则设置new值
&public&final&boolean&compareAndSet(int&expect,&int&new)本文出自 “” 博客,请务必保留此出处
了这篇文章
类别:┆阅读(0)┆评论(0)

我要回帖

更多关于 java int类型 的文章

 

随机推荐