blog.csdn.net/nanhuaibeian/article/details/120936139

一、為什么引入 AtomicInteger ？

談到線程安全，會首先想到了synchronized 和 Lock,但是這種方式又有一個名字，叫做互斥鎖，一次只能有一個持有鎖的線程進入，再加上還有不同線程爭奪鎖這個機制，效率比較低，所以又稱 悲觀鎖

與之相對應(yīng)，就有了 樂觀鎖 的概念：它不加鎖去完成某項操作，如果因為沖突失敗就重試，直到成功為止。

AtomicInteger 保證線程安全就是使用了樂觀鎖，所以相對于悲觀鎖，效率更高。

在有多個線程同時使用CAS操作一個變量時，只有一個會勝出并成功更新，其余均會失敗。失敗的線程不會被掛起，僅被告知失敗，并且允許再次嘗試，當然，也允許失敗的線程放棄操作

二、AtomicInteger 原理分析

1. 具體使用

假如我們想實現(xiàn)一個功能來統(tǒng)計網(wǎng)頁訪問量，可以使用 count++ 來統(tǒng)計訪問量，但是這個自增操作不是線程安全的。

加鎖實現(xiàn)：

class?Counter?{private?volatile?int?count?=?0;public?synchronized?void?increment()?{count++;}public?int?getCount()?{return?count;} }

AtomicInteger 實現(xiàn)：

class?Counter?{//使用AtomicInteger之后，不需要加鎖，也可以實現(xiàn)線程安全。private?AtomicInteger?count?=?new?AtomicInteger();public?void?increment()?{count.incrementAndGet();}public?int?getCount()?{return?count.get();} }

2. 原理分析

AtomicInteger 類中定義的屬性：

//?setup?to?use?Unsafe.compareAndSwapInt?for?updatesprivate?static?final?Unsafe?unsafe?=?Unsafe.getUnsafe();private?static?final?long?valueOffset;static?{try?{valueOffset?=?unsafe.objectFieldOffset(AtomicInteger.class.getDeclaredField("value"));}?catch?(Exception?ex)?{?throw?new?Error(ex);?}}

Unsafe是JDK內(nèi)部的工具類，主要實現(xiàn)了平臺相關(guān)的操作

sun.misc.Unsafe 是JDK內(nèi)部用的工具類。它通過暴露一些Java意義上說“不安全”的功能給Java層代碼，來讓JDK能夠更多的使用Java代碼來實現(xiàn)一些原本是平臺相關(guān)的、需要使用native語言（例如C或C++）才可以實現(xiàn)的功能。該類不應(yīng)該在JDK核心類庫之外使用。

簡單來說：這段代碼是為了獲取value在堆內(nèi)存中的偏移量

Value的定義：

private?volatile?int?value;

volatile 主要特性有兩點：防止重排序；實現(xiàn)內(nèi)存可見性

內(nèi)存可見性的作用是當一個線程修改了共享變量時，另一個線程可以讀取到這個修改后的值

用CAS操作實現(xiàn)原子性：

AtomicInteger中有很多方法，例如

• incrementAndGet() 相當于i++ ；

• getAndAdd() 相當于i+=n 。

從源碼中我們可以看出這幾種方法的實現(xiàn)很相似，這里主要分析incrementAndGet()方法的源碼

public?final?int?incrementAndGet()?{for?(;;)?{int?current?=?get();int?next?=?current?+?1;if?(compareAndSet(current,?next))return?next;}}public?final?boolean?compareAndSet(int?expect,?int?update)?{return?unsafe.compareAndSwapInt(this,?valueOffset,?expect,?update);}

incrementAndGet() 方法實現(xiàn)了自增的操作。

核心實現(xiàn)是先獲取當前值和目標值（也就是current +1），如果compareAndSet(current, next) 返回成功則該方法返回目標值。

那么compareAndSet是做CAS操作

每次從內(nèi)存中根據(jù)內(nèi)存偏移量（valueOffset）取出數(shù)據(jù)，將取出的值跟expect 比較，如果數(shù)據(jù)一致就把內(nèi)存中的值改為update，如果數(shù)據(jù)不一致說明內(nèi)存中的數(shù)據(jù)已經(jīng)有過更新，此時就進行回滾(expect值不生效)操作。

這樣使用CAS的方法就保證了原子操作

Java中的 AtomicLong、AtomicBoolean 等方法的基本原理和思想跟AtomicInteger基本相同

三、總結(jié)

（1）用volatile關(guān)鍵字修飾 value 字段，保證了 value 字段對各個線程的可見性，各線程讀取value字段時，會先從主從把數(shù)據(jù)同步到工作內(nèi)存中，這樣保證可見性

（2）Unsafe 實現(xiàn)操作原子性，用戶在使用時無需增加額外的同步操作，compareAndSetInt方法是一個CAS操作，用native關(guān)鍵字修飾

原理：先比較內(nèi)存中的值與expected是否一致，一致的前提下才賦予新的值x，此時返回true，否則返回false

往期推薦

如何保證數(shù)據(jù)庫和緩存雙寫一致性？

Spring官方推薦的@Transactional還能導(dǎo)致生產(chǎn)事故？

MySQL 精選 60 道面試題（含答案）

總結(jié)

以上是生活随笔為你收集整理的面试官：AtomicInteger是如何保证线程安全？的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

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