JDK1.5提供了java.util.concurrent.atomic包,可以線程安全的更新一個(gè)變量库糠。
Atomic包里一個(gè)提供了12個(gè)類,屬于4種類型的原子更新方式:
- 原子更新基本類型
- 原子更新數(shù)組
- 原子更新引用
- 原子更新屬性(字段)
原子更新基本類型類
使用原子的方式更新基本類型只泼。包括下面3個(gè)類:
AtomicBoolean:boolean類型
AtomicInteger:原子更新整形
AtomicLong:原子更新長(zhǎng)整形
AtomicInteger常用方法:
-
int addAndGet(int delta)
:相加并返回結(jié)果 -
boolean compareAndSet(int expect, int update)
:如果當(dāng)前值等于預(yù)期值遇汞,那么將該值設(shè)置為輸入的值昼丑。 -
int getAndIncrement()
:返回當(dāng)前值呻逆,然后將當(dāng)前值加一 -
void lazySet(int newValue)
:最終會(huì)設(shè)置成newValue,但是在設(shè)置值之后菩帝,其他線程在一段時(shí)間內(nèi)還可以讀到舊的值咖城。 -
int getAndSet(int newValue)
:返回當(dāng)前值,然后將當(dāng)前值設(shè)置成新值呼奢。
package com.atomic;
import java.util.concurrent.atomic.AtomicInteger;
public class AtomicIntegerTest {
static AtomicInteger ai = new AtomicInteger(1);
public static void main(String[] args) {
System.out.println(ai.getAndIncrement());//1
System.out.println(ai.get());//2
}
}
原子更新數(shù)組
通過原子的方式更新數(shù)組中的某個(gè)元素宜雀,Atomic包提供了一下3個(gè)類:
-
AtomicIntegerArray
:原子更新整形數(shù)組里的元素 -
AtomicLongArray
:原子更新長(zhǎng)整形數(shù)組里的元素 -
AtomicReferenceArray
:原子更新引用類型數(shù)組里的元素
注意:數(shù)組通過構(gòu)造方法傳給AtomicIntegerArray會(huì)將當(dāng)前的數(shù)組復(fù)制一份,以后在復(fù)制的對(duì)象上進(jìn)行操作握础。不會(huì)更改原來數(shù)組的值辐董。
AtomicIntegerArray
主要提供原子的方式更新數(shù)組里的整形:
-
int addAndGet(int i, int delta)
:原子方式將輸入值與數(shù)組里索引i的元素相加。 -
boolean compareAndSet(int i, int expect, int update)
:如果當(dāng)前值等于預(yù)期值弓候,則以原子方式將數(shù)組位置i的元素設(shè)置成update值
package com.atomic;
import java.util.concurrent.atomic.AtomicIntegerArray;
public class AtomicIntegerArrayTest {
static int[] value = new int[] {1,2};
public static void main(String[] args) {
AtomicIntegerArray ai = new AtomicIntegerArray(value);
System.out.println(ai.getAndSet(0, 3));
System.out.println(ai.get(0));
System.out.println(value[0]);
}
}
/*
1
3
1
*/
原子更新引用類型
Atomic包提供了3個(gè)類:
-
AtomicReference
:原子更新引用類型 -
AtomicReferenceFieldUpdater
:原子更新引用類型里的字段 -
AtomicMarkableReference
:原子更新帶有標(biāo)志位的引用類型∷耍可以原子更新一個(gè)布爾類型的標(biāo)記位和引用類型菇存。構(gòu)造方法是AtomicMarkableReference(V initialRef, boolean initialMark)
package com.atomic;
import java.util.concurrent.atomic.AtomicReference;
public class AtomicReferenceTest {
public static AtomicReference<User> atomicUserRef = new AtomicReference<User>();
public static void main(String[] args) {
User user = new User("張三",10);
atomicUserRef.set(user);
User updateUser = new User("李四",11);
atomicUserRef.compareAndSet(user, updateUser);
System.out.println(atomicUserRef.get().getName());
System.out.println(atomicUserRef.get().getOld());
}
static class User{
private String name;
private int old;
public User(String name, int old) {
super();
this.name = name;
this.old = old;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public int getOld() {
return old;
}
public void setOld(int old) {
this.old = old;
}
}
}
原子更新字段類
需要原子更新某個(gè)類里的某個(gè)字段時(shí),需要使用原子更新字段類邦蜜。Atomic包提供了3個(gè)類:
-
AtomicIntegerFieldUpdate
:原子更新整形的字段的更新器 -
AtomicLongFieldUpdate
:原子更新長(zhǎng)整形的字段的更新器 -
AtomicStampedReference
:原子更新帶有版本號(hào)的引用類型
想要原子的更新字段類需要兩步:
- 因?yàn)樵痈伦侄晤惗际浅橄箢愐琅福看问褂玫臅r(shí)候必須使用靜態(tài)方法
newUpdater()
創(chuàng)建一個(gè)更新器,并且需要設(shè)置想要更新的類和屬性悼沈。 - 更新類的字段必須使用public volatile修飾符贱迟。
注意:
被更新的字段必須是public volatile
。
package com.atomic;
import java.util.concurrent.atomic.AtomicIntegerFieldUpdater;
public class AtomicIntegerFieldUpdaterTest {
//創(chuàng)建原子更新器絮供,并設(shè)置需要更新的類和字段
private static AtomicIntegerFieldUpdater<User> a = AtomicIntegerFieldUpdater.newUpdater(User.class, "old");
public static void main(String[] args) {
//設(shè)置柯南10歲
User conan = new User("conan", 10);
//長(zhǎng)一歲衣吠,但是還返回之前的年齡
System.out.println(a.getAndIncrement(conan));
//輸出現(xiàn)在年齡
System.out.println(a.get(conan));
}
static class User{
private String name;
public volatile int old;
public User(String name, int old) {
this.name = name;
this.old = old;
}
public String getName() {
return name;
}
public int getOld() {
return old;
}
}
}