在Java語(yǔ)言中，++i和i++操作并不是線程安全的，在使用的時(shí)候，不可避免的會(huì)用到synchronized關(guān)鍵字。而AtomicInteger則通過(guò)一種線程安全的加減操作接口 [java]?view plaincopy

import?java.util.concurrent.atomic.AtomicInteger;??

??

public?class?AtomicIntegerTest?{??

????public?AtomicInteger?inc?=?new?AtomicInteger();??

??

????public?void?increase()?{??

????????inc.getAndIncrement();//i++操作??

????????//inc.getAndDecrement();//i--操作??

????}??

??

????public?static?void?main(String[]?args)?{??

????????final?AtomicIntegerTest?test?=?new?AtomicIntegerTest();??

????????for?(int?i?=?0;?i?<?10;?i++)?{??

????????????new?Thread()?{??

????????????????public?void?run()?{??

????????????????????for?(int?j?=?0;?j?<?1000;?j++)??

????????????????????????test.increase();??

????????????????};??

????????????}.start();??

????????}??

??

????????while?(Thread.activeCount()?>?1)??

????????????//?保證前面的線程都執(zhí)行完??

????????????Thread.yield();??

????????System.out.println(test.inc);??

????}??

}??

　可以發(fā)現(xiàn)結(jié)果都是10000，也就是說(shuō)AtomicInteger是線程安全的。

值得一看。

這里，我們來(lái)看看AtomicInteger是如何使用非阻塞算法來(lái)實(shí)現(xiàn)并發(fā)控制的。

AtomicInteger的關(guān)鍵域只有一下3個(gè)：

[java]?view plaincopy

//?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提供的獲得對(duì)對(duì)象內(nèi)存地址訪問(wèn)的類，注釋已經(jīng)清楚的寫(xiě)出了，它的作用就是在更新操作時(shí)提供“比較并替換”的作用。實(shí)際上就是AtomicInteger中的一個(gè)工具。

valueOffset是用來(lái)記錄value本身在內(nèi)存的便宜地址的，這個(gè)記錄，也主要是為了在更新操作在內(nèi)存中找到value的位置，方便比較。

注意：value是用來(lái)存儲(chǔ)整數(shù)的時(shí)間變量，這里被聲明為volatile，就是為了保證在更新操作時(shí)，當(dāng)前線程可以拿到value最新的值（并發(fā)環(huán)境下，value可能已經(jīng)被其他線程更新了）。

這里，我們以自增的代碼為例，可以看到這個(gè)并發(fā)控制的核心算法：

[java]?view plaincopy

/**?

*?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方法，實(shí)現(xiàn)高效的硬件級(jí)別CAS??

return?unsafe.compareAndSwapInt(this,?valueOffset,?expect,?update);??

}??

?好了，看到這個(gè)代碼，基本上就看到這個(gè)類的核心了。相對(duì)來(lái)說(shuō)，其實(shí)這個(gè)類還是比較簡(jiǎn)單的。可以參考http://hittyt.iteye.com/blog/1130990 創(chuàng)作挑戰(zhàn)賽新人創(chuàng)作獎(jiǎng)勵(lì)來(lái)咯，堅(jiān)持創(chuàng)作打卡瓜分現(xiàn)金大獎(jiǎng)

總結(jié)

以上是生活随笔為你收集整理的多线程1:AtomicInteger的使用,多线程叠加或叠减的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。