資訊專欄INFORMATION COLUMN
摘要：本文主要介紹下中的主要操作。所謂的內(nèi)存屏障，是之虛擬機(jī)在對(duì)于這樣的語(yǔ)句，在及后續(xù)寫入操作執(zhí)行前，保證的寫入操作對(duì)其它處理器可見。是會(huì)插入的內(nèi)存屏障，效率略低本篇為俺的課堂基礎(chǔ)手寫的前置知識(shí)，歡迎大家圍觀
Unsafe是Java無(wú)鎖操作的基石，在無(wú)鎖并發(fā)類中都少不了它們的身影，比如ConcurrentHashMap, ConcurrentLinkedQueue, 都是由Unsafe類來(lái)實(shí)現(xiàn)的。相對(duì)于與Java中的鎖，它基本無(wú)開銷，會(huì)原地等待。本文主要介紹下Unsafe中的主要操作。
1 compareAndSwap/** * 比較obj的offset處內(nèi)存位置中的值和期望的值，如果相同則更新。此更新是不可中斷的。 * * @param obj 需要更新的對(duì)象 * @param offset obj中整型field的偏移量 * @param expect 希望field中存在的值 * @param update 如果期望值expect與field的當(dāng)前值相同，設(shè)置filed的值為這個(gè)新值 * @return 如果field的值被更改返回true */ public native boolean compareAndSwapInt(Object obj, long offset, int expect, int update);
這個(gè)就是著名的CAS操作了，分為三步來(lái)做
獲取obj對(duì)象中為offset的偏移值，這里假設(shè)為realVal
比較realVal和expect
如果相同，將該值更新為update，否則不更新
CAS家族還包括有，compareAndSwapObject(), compareAndSwapLong(), compareAndSwapInt()等等
用AtomicInteger中一個(gè)經(jīng)典的例子來(lái)說(shuō)明：
public final int getAndAdd(int delta) {
return unsafe.getAndAddInt(this, valueOffset, delta);
}
//unsafe.getAndAddInt
public final int getAndAddInt(Object var1, long var2, int var4) {
int var5;
do {
/**獲取原始值*/
var5 = this.getIntVolatile(var1, var2);
/**確認(rèn)原始值沒(méi)有被其它線程修改時(shí)，再執(zhí)行更新var5+var4操作，如果
被其它線程修改過(guò)了，則會(huì)原地等待，持續(xù)循環(huán)*/
} while(!this.compareAndSwapInt(var1, var2, var5, var5 + var4));
return var5;
}
這里可以看出CAS操作存在的問(wèn)題，在低競(jìng)態(tài)情況下是ok的，但是在高競(jìng)態(tài)情況下，while循環(huán)會(huì)一直消耗cpu資源
2 putOrder/*** * Sets the value of the integer field at the specified offset in the * supplied object to the given value. This is an ordered or lazy * version ofputIntVolatile(Object,long,int), which * doesn"t guarantee the immediate visibility of the change to other * threads. It is only really useful where the integer field is *volatile, and is thus expected to change unexpectedly. * * @param obj the object containing the field to modify. * @param offset the offset of the integer field withinobj. * @param value the new value of the field. * @see #putIntVolatile(Object,long,int) */ public native void putOrderedInt(Object obj, long offset, int value);
將obj對(duì)象的偏移量為offset的位置修改為value，因?yàn)镴ava中沒(méi)有內(nèi)存操作，而Unsafe的這個(gè)操作正好補(bǔ)充了內(nèi)存操作的不足。也可以用于數(shù)組操作，比如ConcurrentHashMap中就大量用到了該操作
