AtomicInteger的用法

在Java語言中，++i和i++操做並非線程安全的，在使用的時候，不可避免的會用到synchronized關鍵字。而AtomicInteger則經過一種線程安全的加減操做接口。咳喲參考我以前寫的一篇博客http://www.cnblogs.com/sharkli/p/5597148.html,今天偶然發現能夠不用synchronized使用AtomicInteger完成一樣的功能，具體代碼以下，

package TestAtomicInteger;
 
import java.util.concurrent.atomic.AtomicInteger;
 
class MyThread implements Runnable {
//    static  int i = 0;
     static AtomicInteger ai=new AtomicInteger(0);
      
 
    public void run() {
        for (int m = 0; m < 1000000; m++) {
            ai.getAndIncrement();
        }
    }
};
 
public class TestAtomicInteger {
    public static void main(String[] args) throws InterruptedException {
        MyThread mt = new MyThread();
 
        Thread t1 = new Thread(mt);
        Thread t2 = new Thread(mt);
        t1.start();
        t2.start();
        Thread.sleep(500);
        System.out.println(MyThread.ai.get());
    }
}

　　能夠發現結果都是2000000，也就是說AtomicInteger是線程安全的。

值得一看。

這裏，咱們來看看AtomicInteger是如何使用非阻塞算法來實現併發控制的。

AtomicInteger的關鍵域只有一下3個：

// setup to use Unsafe.compareAndSwapInt for updates  
private static final Unsafe unsafe = Unsafe.getUnsafe();  
private static final long valueOffset;  
private volatile int value;

這裏， unsafe是java提供的得到對對象內存地址訪問的類，註釋已經清楚的寫出了，它的做用就是在更新操做時提供「比較並替換」的做用。實際上就是AtomicInteger中的一個工具。

valueOffset是用來記錄value自己在內存的便宜地址的，這個記錄，也主要是爲了在更新操做在內存中找到value的位置，方便比較。

注意：value是用來存儲整數的時間變量，這裏被聲明爲volatile，就是爲了保證在更新操做時，當前線程能夠拿到value最新的值（併發環境下，value可能已經被其餘線程更新了）。

這裏，咱們以自增的代碼爲例，能夠看到這個併發控制的核心算法：

/**
* Atomically increments by one the current value.
*
* @return the updated value
*/
public final int incrementAndGet() {
for (;;) {
//這裏能夠拿到value的最新值
int current = get();
int next = current + 1;
if (compareAndSet(current, next))
return next;
}
}

public final boolean compareAndSet(int expect, int update) {
//使用unsafe的native方法，實現高效的硬件級別CAS
return unsafe.compareAndSwapInt(this, valueOffset, expect, update);
}

好了，看到這個代碼，基本上就看到這個類的核心了。相對來講，其實這個類仍是比較簡單的。能夠參考http://hittyt.iteye.com/blog/1130990； Java.util.concurrent中實現的原子操做類包括： AtomicBoolean、AtomicInteger、AtomicLong、AtomicReference。