偷偷摘套内射激情视频,久久精品99国产国产精,中文字幕无线乱码人妻,中文在线中文a,性爽19p

Java并發(fā)編程包中atomic的實(shí)現(xiàn)原理

開發(fā) 開發(fā)工具
在多線程的場(chǎng)景中,我們需要保證數(shù)據(jù)安全,就會(huì)考慮同步的方案,通常會(huì)使用synchronized或者lock來處理,使用了synchronized意味著內(nèi)核態(tài)的一次切換。這是一個(gè)很重的操作。

 這是一篇來自粉絲的投稿,作者【林灣村龍貓】最近在閱讀Java源碼,這一篇是他關(guān)于并發(fā)包中atomic類的源碼閱讀的總結(jié)。Hollis做了一點(diǎn)點(diǎn)修改。

引子

在多線程的場(chǎng)景中,我們需要保證數(shù)據(jù)安全,就會(huì)考慮同步的方案,通常會(huì)使用synchronized或者lock來處理,使用了synchronized意味著內(nèi)核態(tài)的一次切換。這是一個(gè)很重的操作。

有沒有一種方式,可以比較便利的實(shí)現(xiàn)一些簡(jiǎn)單的數(shù)據(jù)同步,比如計(jì)數(shù)器等等。concurrent包下的atomic提供我們這么一種輕量級(jí)的數(shù)據(jù)同步的選擇。

使用例子

  1. import java.util.concurrent.CountDownLatch; 
  2. import java.util.concurrent.atomic.AtomicInteger; 
  3.  
  4. public class App { 
  5.  
  6.     public static void main(String[] args) throws Exception { 
  7.         CountDownLatch countDownLatch = new CountDownLatch(100); 
  8.  
  9.         AtomicInteger atomicInteger = new AtomicInteger(0); 
  10.         for (int i = 0; i < 100; i++) { 
  11.             new Thread() { 
  12.                 @Override 
  13.                 public void run() { 
  14.                     atomicInteger.getAndIncrement(); 
  15.  
  16.                     countDownLatch.countDown(); 
  17.                 } 
  18.             }.start(); 
  19.         } 
  20.  
  21.         countDownLatch.await(); 
  22.  
  23.         System.out.println(atomicInteger.get()); 
  24.     } 

在以上代碼中,使用AtomicInteger聲明了一個(gè)全局變量,并且在多線程中進(jìn)行自增,代碼中并沒有進(jìn)行顯示的加鎖。

以上代碼的輸出結(jié)果,永遠(yuǎn)都是100。如果將AtomicInteger換成Integer,打印結(jié)果基本都是小于100。

也就說明AtomicInteger聲明的變量,在多線程場(chǎng)景中的自增操作是可以保證線程安全的。接下來我們分析下其原理。

原理

我們可以看一下AtomicInteger的代碼

他的值是存在一個(gè)volatile的int里面。volatile只能保證這個(gè)變量的可見性。不能保證他的原子性。

可以看看getAndIncrement這個(gè)類似i++的函數(shù),可以發(fā)現(xiàn),是調(diào)用了UnSafe中的getAndAddInt。

UnSafe是何方神圣?UnSafe提供了java可以直接操作底層的能力。

進(jìn)一步,我們可以發(fā)現(xiàn)實(shí)現(xiàn)方式:

如何保證原子性:自旋 + CAS(樂觀鎖)。在這個(gè)過程中,通過compareAndSwapInt比較更新value值,如果更新失敗,重新獲取舊值,然后更新。

優(yōu)缺點(diǎn)

CAS相對(duì)于其他鎖,不會(huì)進(jìn)行內(nèi)核態(tài)操作,有著一些性能的提升。但同時(shí)引入自旋,當(dāng)鎖競(jìng)爭(zhēng)較大的時(shí)候,自旋次數(shù)會(huì)增多。cpu資源會(huì)消耗很高。

換句話說,CAS+自旋適合使用在低并發(fā)有同步數(shù)據(jù)的應(yīng)用場(chǎng)景。

Java 8做出的改進(jìn)和努力

在Java 8中引入了4個(gè)新的計(jì)數(shù)器類型,LongAdder、LongAccumulator、DoubleAdder、DoubleAccumulator。他們都是繼承于Striped64。

在LongAdder 與AtomicLong有什么區(qū)別?

Atomic*遇到的問題是,只能運(yùn)用于低并發(fā)場(chǎng)景。因此LongAddr在這基礎(chǔ)上引入了分段鎖的概念??梢詤⒖肌禞DK8系列之LongAdder解析》一起看看做了什么。

大概就是當(dāng)競(jìng)爭(zhēng)不激烈的時(shí)候,所有線程都是通過CAS對(duì)同一個(gè)變量(Base)進(jìn)行修改,當(dāng)競(jìng)爭(zhēng)激烈的時(shí)候,會(huì)將根據(jù)當(dāng)前線程哈希到對(duì)于Cell上進(jìn)行修改(多段鎖)。

可以看到大概實(shí)現(xiàn)原理是:通過CAS樂觀鎖保證原子性,通過自旋保證當(dāng)次修改的最終修改成功,通過降低鎖粒度(多段鎖)增加并發(fā)性能。

【本文是51CTO專欄作者Hollis的原創(chuàng)文章,作者微信公眾號(hào)Hollis(ID:hollischuang)】

戳這里,看該作者更多好文

責(zé)任編輯:武曉燕 來源: 51CTO專欄
相關(guān)推薦

2025-03-20 06:48:55

性能優(yōu)化JDK

2023-12-01 08:54:50

Java原子類型

2023-12-04 13:48:00

編 程Atomic

2023-07-05 08:18:54

Atomic類樂觀鎖悲觀鎖

2021-06-07 17:12:22

線程安全Atomic

2025-07-25 06:48:26

Java編程并發(fā)編程

2025-08-05 06:00:00

并發(fā)編程Java開發(fā)

2021-08-05 07:58:22

并發(fā)編程包Task

2020-12-04 19:28:53

CountDownLaPhaserCyclicBarri

2020-12-03 11:15:21

CyclicBarri

2022-11-09 09:01:08

并發(fā)編程線程池

2020-11-30 16:01:03

Semaphore

2020-12-16 10:54:52

編程ForkJoin框架

2020-12-09 08:21:47

編程Exchanger工具

2012-06-17 12:49:03

并發(fā)并發(fā)編程

2025-08-01 06:00:00

死鎖并發(fā)編程Java

2019-09-16 08:45:53

并發(fā)編程通信

2025-08-25 06:05:00

代碼并發(fā)編程等待通知模型

2021-12-27 10:13:51

Goatomic數(shù)據(jù)競(jìng)爭(zhēng)

2022-12-26 09:27:48

Java底層monitor
點(diǎn)贊
收藏

51CTO技術(shù)棧公眾號(hào)