Java多線程進(jìn)階（十三）—— J.U.C之a(chǎn)tomic框架：AtomicInteger

darkbug 發(fā)布于2019-08-19 10:51 / 1608人閱讀

摘要：顧名思義，是類型的線程安全原子類，可以在應(yīng)用程序中以原子的方式更新值。創(chuàng)建對象先來看下對象的創(chuàng)建。也就是說當(dāng)一個(gè)線程修改一個(gè)共享變量時(shí)，其它線程能立即讀到這個(gè)修改的值。

本文首發(fā)于一世流云的專欄：https://segmentfault.com/blog...

一、AtomicInteger簡介

AtomicInteger，應(yīng)該是atomic框架中用得最多的原子類了。顧名思義，AtomicInteger是Integer類型的線程安全原子類，可以在應(yīng)用程序中以原子的方式更新int值。

1. 創(chuàng)建AtomicInteger對象

先來看下AtomicInteger對象的創(chuàng)建。

AtomicInteger提供了兩個(gè)構(gòu)造器，使用默認(rèn)構(gòu)造器時(shí)，內(nèi)部int類型的value值為0：
AtomicInteger atomicInt = new AtomicInteger();

AtomicInteger類的內(nèi)部并不復(fù)雜，所有的操作都針對內(nèi)部的int值——value，并通過Unsafe類來實(shí)現(xiàn)線程安全的CAS操作：

2. AtomicInteger的使用

來看下面這個(gè)示例程序：

public class Main {
    public static void main(String[] args) throws InterruptedException {
        AtomicInteger ai = new AtomicInteger();

        List list = new ArrayList<>();
        for (int i = 0; i < 10; i++) {
            Thread t = new Thread(new Accumlator(ai), "thread-" + i);
            list.add(t);
            t.start();
        }

        for (Thread t : list) {
            t.join();
        }

        System.out.println(ai.get());
    }

    static class Accumlator implements Runnable {
        private AtomicInteger ai;

        Accumlator(AtomicInteger ai) {
            this.ai = ai;
        }

        @Override
        public void run() {
            for (int i = 0, len = 1000; i < len; i++) {
                ai.incrementAndGet();
            }
        }
    }
}

上述代碼使用了AtomicInteger的incrementAndGet方法，以原子的操作對int值進(jìn)行自增，該段程序執(zhí)行的最終結(jié)果為10000（10個(gè)線程，每個(gè)線程對AtomicInteger增加1000），如果不使用AtomicInteger，使用原始的int或Integer，最終結(jié)果值可能會小于10000（并發(fā)時(shí)讀到了過時(shí)的數(shù)據(jù)或存在值覆蓋的問題）。

我們來看下incrementAndGet內(nèi)部：

內(nèi)部調(diào)用了Unsafe類的getAndAddInt方法，以原子方式將value值增加1，然后返回增加前的原始值。

注意，上述是JDK1.8的實(shí)現(xiàn)，在JDK1.8之前，上述方法采用了自旋+CAS操作的方式：

public final int getAndIncrement() {
    for (;;) {
        int current = get();
        int next = current + 1;
        if (compareAndSet(current, next))
            return current;
    }
}

3. AtomicInteger的特殊方法說明

AtomicInteger中有一個(gè)比較特殊的方法——lazySet：

lazySet方法是set方法的不可見版本。什么意思呢？

我們知道通過volatile修飾的變量，可以保證在多處理器環(huán)境下的“可見性”。也就是說當(dāng)一個(gè)線程修改一個(gè)共享變量時(shí)，其它線程能立即讀到這個(gè)修改的值。volatile的實(shí)現(xiàn)最終是加了內(nèi)存屏障：

保證寫volatile變量會強(qiáng)制把CPU寫緩存區(qū)的數(shù)據(jù)刷新到內(nèi)存

讀volatile變量時(shí)，使緩存失效，強(qiáng)制從內(nèi)存中讀取最新的值

由于內(nèi)存屏障的存在，volatile變量還能阻止重排序

lazySet內(nèi)部調(diào)用了Unsafe類的putOrderedInt方法，通過該方法對共享變量值的改變，不一定能被其他線程立即看到。也就是說以普通變量的操作方式來寫變量。

為什么會有這種奇怪方法？什么情況下需要使用lazySet呢？

考慮下面這樣一個(gè)場景：

private AtomicInteger ai = new AtomicInteger();
lock.lock();
try
{
    // ai.set(1);
}
finally
{
    lock.unlock();
}

由于鎖的存在：

lock()方法獲取鎖時(shí)，和volatile變量的讀操作一樣，會強(qiáng)制使CPU緩存失效，強(qiáng)制從內(nèi)存讀取變量。

unlock()方法釋放鎖時(shí)，和volatile變量的寫操作一樣，會強(qiáng)制刷新CPU寫緩沖區(qū)，把緩存數(shù)據(jù)寫到主內(nèi)存

所以，上述ai.set(1)可以用ai.lazySet(1)方法替換：

由鎖來保證共享變量的可見性，以設(shè)置普通變量的方式來修改共享變量，減少不必要的內(nèi)存屏障，從而提高程序執(zhí)行的效率。

二、類/接口說明 類聲明

構(gòu)造器

接口聲明

方法聲明	描述
int accumulateAndGet(int x, IntBinaryOperator accumulatorFunction)	使用IntBinaryOperator 對當(dāng)前值和x進(jìn)行計(jì)算，并更新當(dāng)前值，返回計(jì)算后的新值
int addAndGet(int delta)	以原子方式將給定值與當(dāng)前值相加，返回相加后的新值
boolean compareAndSet(int expect, int update)	如果當(dāng)前值 == expect，則以原子方式將該值設(shè)置為給定的更新值（update）
int decrementAndGet()	以原子方式將當(dāng)前值減 1，返回新值
int get()	獲取當(dāng)前值
int getAndAccumulate(int x, IntBinaryOperator accumulatorFunction)	使用IntBinaryOperator 對當(dāng)前值和x進(jìn)行計(jì)算，并更新當(dāng)前值，返回計(jì)算前的舊值
int getAndAdd(int delta)	以原子方式將給定值與當(dāng)前值相加，返回舊值
int getAndDecrement()	以原子方式將當(dāng)前值減 1，返回舊值
int getAndIncrement()	以原子方式將當(dāng)前值加 1，返回舊值
int getAndSet(int newValue)	以原子方式設(shè)置為給定值，并返回舊值
int getAndUpdate(IntUnaryOperator updateFunction)	使用IntBinaryOperator 對當(dāng)前值進(jìn)行計(jì)算，并更新當(dāng)前值，返回計(jì)算前的舊值
int incrementAndGet()	以原子方式將當(dāng)前值加 1，返回新值
void lazySet(int newValue)	設(shè)置為給定值，但不保證值的改變被其他線程立即看到
void set(int newValue)	設(shè)置為給定值
int updateAndGet(IntUnaryOperator updateFunction)	使用IntBinaryOperator 對當(dāng)前值進(jìn)行計(jì)算，并更新當(dāng)前值，返回計(jì)算后的新值
boolean weakCompareAndSet(int expect, int update)	weakCompareAndSet無法保證除操作目標(biāo)外的其他變量的執(zhí)行順序( 編譯器和處理器為了優(yōu)化程序性能而對指令序列進(jìn)行重新排序 )，同時(shí)也無法保證這些變量的可見性。

三、其它原子類

與AtomicInteger類似的原子類還有AtomicBoolean和AtomicLong，底層都是通過Unsafe類做CAS操作，來原子的更新狀態(tài)值。可以參考Oracle官方文檔：https://docs.oracle.com/javas...，不再贅述。

云服務(wù)器 GPU云服務(wù)器 java多線程多線程調(diào)試 java java多線程分發(fā) java多線程并發(fā)

文章版權(quán)歸作者所有，未經(jīng)允許請勿轉(zhuǎn)載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。

轉(zhuǎn)載請注明本文地址：http://m.hztianpu.com/yun/76561.html

發(fā)表評論

登陸后可評論

0條評論

darkbug

男|高級講師

我要關(guān)注我要私信

TA的文章

stl——容器適配器

閱讀 2594·2021-11-25 09:43
10gbiz，中國香港+美國CN2 GIA線路云服務(wù)器低至$2.36/月，美國站群服務(wù)器首月半價(jià)，香

閱讀 1355·2021-09-07 10:16
Contabo：新增NVME硬盤，€4.99/月起，加€1歐元可以升級100G NVMe硬盤

閱讀 2774·2021-08-20 09:38
什么是Javascript函數(shù)節(jié)流？

閱讀 3017·2019-08-30 15:55
移動端模擬hover：按鈕點(diǎn)擊變色之后還原

閱讀 1587·2019-08-30 13:21
css中幾個(gè)重要概念

閱讀 998·2019-08-29 15:37
XML Notebook

閱讀 1577·2019-08-27 10:56
async/await 異步應(yīng)用的常用場景

閱讀 2164·2019-08-26 13:45

成人无码视频,亚洲精品久久久久av无码,午夜精品久久久久久毛片,亚洲中文字幕日韩无码

資訊專欄INFORMATION COLUMN

上云采購季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺、長期優(yōu)惠，快來選購！

Java多線程進(jìn)階（十三）—— J.U.C之a(chǎn)tomic框架：AtomicInteger

相關(guān)文章

Java多線程進(jìn)階（一）—— J.U.C并發(fā)包概述

Java多線程進(jìn)階（十五）—— J.U.C之atomic框架：Atomic數(shù)組

Java多線程進(jìn)階（十六）—— J.U.C之atomic框架：FieldUpdater

Java多線程進(jìn)階（十二）—— J.U.C之atomic框架：Unsafe類

Java多線程進(jìn)階（十四）—— J.U.C之atomic框架：AtomicReference

發(fā)表評論

0條評論

darkbug

男|高級講師

TA的文章

stl——容器適配器

10gbiz，中國香港+美國CN2 GIA線路云服務(wù)器低至$2.36/月，美國站群服務(wù)器首月半價(jià)，香

Contabo：新增NVME硬盤，€4.99/月起，加€1歐元可以升級100G NVMe硬盤

什么是Javascript函數(shù)節(jié)流？

移動端模擬hover：按鈕點(diǎn)擊變色之后還原

css中幾個(gè)重要概念

XML Notebook

async/await 異步應(yīng)用的常用場景

最新活動

資訊專欄INFORMATION COLUMN

上云采購季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺、長期優(yōu)惠，快來選購！

Java多線程進(jìn)階（十三）—— J.U.C之a(chǎn)tomic框架：AtomicInteger

相關(guān)文章

發(fā)表評論

0條評論

男|高級講師

TA的文章

最新活動

上云采購季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺、長期優(yōu)惠，快來選購！