多線程系列(四) -volatile關鍵字使用詳解

来源:https://www.cnblogs.com/dxflqm/p/18022824
-Advertisement-
Play Games

在上篇文章中,我們介紹到在多線程環境下,如果編程不當,可能會出現程式運行結果混亂的問題。出現這個原因主要是,JMM 中主記憶體和線程工作記憶體的數據不一致,以及多個線程執行時無序,共同導致的結果。 ...


一、簡介

在上篇文章中,我們介紹到在多線程環境下,如果編程不當,可能會出現程式運行結果混亂的問題。

出現這個原因主要是,JMM 中主記憶體和線程工作記憶體的數據不一致,以及多個線程執行時無序,共同導致的結果。

同時也提到引入synchronized同步鎖,可以保證線程同步,讓多個線程依次排隊執行被synchronized修飾的方法或者方法塊,使程式的運行結果與預期一致。

不可否認,採用synchronized同步鎖確實可以保證線程安全,但是它對服務性能的消耗也很大,synchronized是一個獨占式的同步鎖,比如當多個線程嘗試獲取鎖時,其中一個線程獲取到鎖之後,未獲取到鎖的線程會不斷的嘗試獲取鎖,而不會發生中斷,當衝突嚴重的時候,線程會直接進入阻塞狀態,不能再乾別的活。

為了實現線程之間更加方便的訪問共用變數,Java 編程語言還提供了另一種同步機制:volatile域變數,在某些場景下使用它會更加方便。

一般來說,被volatile修飾的變數,可以保證所有線程看到這個變數都是同一個值,同時它不會引起線程上下文的切換和調度,相比synchronizedvolatile更加的輕量化。

比較官方的解釋,volatile修飾變數有以下幾個作用:

  • 1.保證變數的可見性,不保證原子性
    當用volatile修飾一個變數時,JMM 會把當前線程本地記憶體中的變數強制刷新到主記憶體中去,這個寫操作也會導致其他線程中被volatile修飾的變數緩存無效,然後從主記憶體中獲取最新的值

  • 2.禁止指令重排
    正常情況下,編譯器和處理器為了優化程式執行性能會對指令序列進行重排序,當然是在不影響程式結果的前提下。volatile能夠在一定程度上禁止 JVM 進行指令重排。

從概念上感覺比較難理解,下麵我們結合幾個例子,一起來看看它的具體應用。

二、volatile 使用詳解

我們先看一個例子。

public class DataEntity {

    private boolean isRunning = true;

    public void addCount(){
        System.out.println("線程運行開始....");
        while (isRunning){ }
        System.out.println("線程運行結束....");
    }

    public boolean isRunning() {
        return isRunning;
    }

    public void setRunning(boolean running) {
        isRunning = running;
    }
}
public class MyThread extends Thread {

    private DataEntity entity;

    public MyThread(DataEntity entity) {
        this.entity = entity;
    }

    @Override
    public void run() {
        entity.addCount();
    }
}
public class MyThreadTest {

    public static void main(String[] args) throws InterruptedException {
        // 初始化數據實體
        DataEntity entity = new DataEntity();

        MyThread threadA = new MyThread(entity);
        threadA.start();

        // 主線程阻塞1秒
        Thread.sleep(1000);

        // 將運行狀態設置為false
        entity.setRunning(false);
    }
}

運行結果如下:

從實際運行結果來看,程式進入死迴圈狀態,雖然最後一行手動設置了entity.setRunning(false),但是沒有起到任何的作用。

原因其實也很簡單,雖然主線程mainisRunning變數設置為false,但是線程threadA 裡面的isRunning變數還是true,兩個線程看到的數據不一致。

假如在isRunning變數上,加一個volatile關鍵字,我們再來看看運行效果。

/**
 * 在 isRunning 變數上加一個 volatile 關鍵字
 */
private volatile boolean isRunning = true;

運行結果如下:

程式運行後自動結束。

說明當主線程mainisRunning變數設置為false時,線程threadA 裡面的isRunning值也隨著發生變化。

說明被volatile修飾的變數,在多線程環境下,可以保證所有線程看到這個變數都是同一個值。

三、volatile 不適用的場景

對於某些場景下,volatile可能並不適用,我們還是先看一個例子。

public class DataEntity {

    private volatile int count = 0;

    public void addCount(){
        for (int i = 0; i < 100000; i++) {
            count++;
        }
    }

    public int getCount() {
        return count;
    }
}
public class MyThreadTest {

    public static void main(String[] args) throws InterruptedException {
        // 初始化數據實體
        DataEntity entity = new DataEntity();

        // 初始化5個線程計數器
        CountDownLatch latch = new CountDownLatch(5);

        // 採用多線程進行操作
        for (int i = 0; i < 5; i++) {
            new Thread(new Runnable() {
                @Override
                public void run() {
                    entity.addCount();
                    //線程運行完畢減1
                    latch.countDown();
                }
            }).start();
        }

        // 等待以上線程執行完畢,再獲取結果
        latch.await();
        System.out.println("result: " + entity.getCount());
    }
}

運行結果如下:

第一次運行:result: 340464
第二次運行:result: 318342
第三次運行:result: 305957

理論上使用 5 個線程分別執行了100000自增,我們預期的結果應該是5*100000=500000,從實際的運行結果可以看出,與預期不一致。

這是因為volatile的作用其實是有限的,它只能保證多個線程之間看到的共用變數值是最新的,但是無法保證多個線程操作共用變數時依次有序,無法保證原子性操作

上面的例子中count++不是一個原子性操作,在處理器看來,其實一共做了三個步驟的操作:讀取數據對數據加 1回寫數據,在多線程隨機執行情況下,輸出結果不能達到預期值。

如果想要實現與預期一致的結果,有以下三種方案可選。

方案一:採用synchronized同步鎖

public class DataEntityC2 {

    private int count = 0;

    /**
     * 採用 synchronized 同步鎖,可以實現多個線程執行方法時串列
     */
    public synchronized void addCount(){
        for (int i = 0; i < 100000; i++) {
            count++;
        }
    }

    public int getCount() {
        return count;
    }
}

方案二:採用Lock

public class DataEntityC2 {

    private int count = 0;

    private Lock lock = new ReentrantLock();

    /**
     * 採用 Lock 鎖,可以實現多個線程執行方法時串列
     */
    public void addCount(){
        for (int i = 0; i < 100000; i++) {
            lock.lock();
            try {
                count++;
            } finally {
                lock.unlock();
            }
        }
    }

    public int getCount() {
        return count;
    }
}

方案三:採用JUC包中的原子操作類

public class DataEntity {

    private AtomicInteger inc = new AtomicInteger();

    /**
     * 採用原子操作類,原子操作類是通過CAS迴圈的方式來保證操作原子性
     */
    public void addCount(){
        for (int i = 0; i < 100000; i++) {
            inc.getAndIncrement();
        }
    }

    public int getCount() {
        return inc.get();
    }
}

以上三種方案,都可以實現程式的運行結果與預期一致!

四、volatile 的原理

通過以上的例子介紹,相信大家對volatile關鍵字的作用有了一些認識。

volatile修飾的變數,可以保證變數在記憶體中的可見性,但是無法保證原子性操作。

關於原子性、可見性和有序性的定義,這三個特性主要從多線程編程安全形度總結出來的一些基本要素,也是併發編程的三大核心基礎,在上篇文章中有所提到過,這裡不再重覆講了。

在 JVM 底層,volatile是通過採用“記憶體屏障”來實現記憶體可見性和禁止指令重排。觀察不加入volatile和加入volatile關鍵字所生成的彙編代碼發現,加入volatile關鍵字的代碼會多出一個lock首碼指令,lock首碼指令實際上相當於一個記憶體屏障,可以提供以下 3 個功能。

  • 1.它確保指令重排序時,不會把後面的指令排到記憶體屏障之前的位置,也不會把前面的指令排到記憶體屏障的後面,禁止處理器對影響程式執行結果的指令進行重排
  • 2.它會強制將緩存的修改操作立刻寫入主存,保證記憶體變數可見
  • 3.如果是寫操作,它會導致其它 CPU 中對應的行緩存無效,目的是讓其他線程中被volatile修飾的變數緩存無效,然後從主記憶體中獲取最新的值

五、單例模式中的雙重檢鎖為什麼要加 volatile?

在上篇文章中,我們提到過單例設計模式中的雙重校驗鎖實現。

public class Singleton {  

    private volatile static Singleton singleton;  
    
    private Singleton (){}  
    
    public static Singleton getSingleton() {  
        if (singleton == null) {  //第一行
            synchronized (Singleton.class) {  //第二行
                if (singleton == null) {  //第三行
                    singleton = new Singleton();  //第四行
                }  
            }  
        }  
        return singleton;  //第五行
    }  
}

synchronized可以保證原子性、可見性和有序性,為什麼變數singleton還需要加volatile關鍵字呢?

之所以需要加volatile關鍵字的原因是:問題出在第一行代碼不在同步代碼塊之類,可能出現這個對象地址不為空,但是內容為空

以初始化一個Singleton singleton = new Singleton();為例,JVM 會分三個步驟完成:

a. memory = allocate() //分配記憶體
b. ctorInstanc(memory) //初始化對象
c. instance = memory   //設置instance指向剛分配的地址

上面的代碼在編譯運行時可能會出現重排序,因為bc無邏輯關聯,執行的順序是a -> b -> c或者a -> c -> b,在多線程的環境下可能會出現問題。

分析過程如下:

  • 1.線程 A 執行到第四行代碼時,線程 B 進來執行第一行代碼
  • 2.假設線程 A 在執行過程中發生了指令重排序,先執行了ac,沒有執行b
  • 3.由於線程 A 執行了c導致instance指向了一段地址,此時線程 B 檢查singleton發現不為null,會直接跳轉到第五行代碼,返回一個未初始化的對象,導致程式會出現報錯
  • 4.因此需要在singleton變數上加一個volatile關鍵字,當線程 A 執行完畢b操作之後,會變數強制刷新到主記憶體中,此時線程 B 也可以拿到最新的對象

這就是為啥雙重檢鎖模式中,singleton變數為啥要加一個volatile關鍵字的原因。

採用雙重檢鎖的方式,可以顯著的提升併發查詢的效率。

六、小結

本篇文章主要圍繞volatile關鍵字的用途、使用方式和一些坑點,做了一個簡單的知識總結,內容難免有所遺漏,歡迎網友留言指出!

七、參考

1、老鼠只愛大米 - Java volatile關鍵字總結


作者:程式員志哥
出處:pzblog.cn
資源:微信搜【程式員志哥】關註我,回覆 【技術資料】有我準備的一線程式必備電腦書籍、大廠面試資料和免費電子書。 希望可以幫助大家提升技術和能力。


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • 我們一般在底層寫方法時,如果方法顯示throws異常,那麼在調用時,也需要將這個異常throws出來,例如 public RetOps<T> assertCode(Integer expect, Function<? super R<T>, ? extends Exception> func) th ...
  • Solana 開發學習之Solana 基礎知識 Install the Solana CLI 相關鏈接 https://docs.solanalabs.com/cli/install https://solanacookbook.com/zh/getting-started/installation ...
  • 前言 當前,微服務架構在很多公司都已經落地實施了,下麵用一張圖簡要概述下微服務架構設計中常用組件。不能說已經使用微服務好幾年了,結果對微服務架構沒有一個整體的認知,一個只懂搬磚的程式員不是一個好碼農。 流量入口Nginx 在上圖中可以看到,Nginx作為整個架構的流量入口,可以理解為一個外部的網關, ...
  • 之前給大家推薦過一些油管上的免費學習資源,如果您還沒有看過的話可以點擊這裡前往。 今天再給大家推薦一批Udemy上超高質量並且免費的編程課程,有需要的小伙伴可以學起來了。 1. JavaScript Essentials 第一門免費課程是:JavaScript Essentials。顧名思義,本課程 ...
  • 在 Java 中,LocalDateTime、Date 和 Instant 分別代表了不同的日期時間類型,它們之間有一些區別和適用場景。 Date: java.util.Date 是 Java 早期的日期時間類,它包含了日期和時間信息,但是在設計上存在一些問題,因此並不推薦在新的代碼中使用。 Dat ...
  • 序言 在數字時代,圖像生成技術正日益成為人工智慧領域的熱點。 本討論將重點聚焦於兩個備受矚目的模型:DALL-E和其他主流AI繪圖方法。 我們將探討它們的優勢、局限性以及未來的發展方向。通過比較分析,我們期望能夠更全面地瞭解這些技術,為未來的研究和應用提供啟示。 Q: 介紹一下 dall-e Ope ...
  • 簡介 git-commit-id-maven-plugin 是一個maven 插件,用來在打包的時候將git-commit 信息打進jar中。 這樣做的好處是可以將發佈的某版本和對應的代碼關聯起來,方便查閱和線上項目的維護。至於它的作用,用官方說法,這個功能對於大型分散式項目來說是無價的。 功能 你 ...
  • 1、下載安裝包首先、進入官網下載安裝包網址:https://www.python.org/downloads/windows/下載步驟:進入下載地址,根據自己的電腦系統選擇相應的python版本 選擇適配64位操作系統的版本(查看自己的電腦操作系統版本), 點擊下載安裝包 也可以下載我百度雲分享的安 ...
一周排行
    -Advertisement-
    Play Games
  • 隨著Aspire發佈preview5的發佈,Microsoft.Extensions.ServiceDiscovery隨之更新, 服務註冊發現這個屬於老掉牙的話題解決什麼問題就不贅述了,這裡主要講講Microsoft.Extensions.ServiceDiscovery(preview5)以及如何 ...
  • 概述:通過使用`SemaphoreSlim`,可以簡單而有效地限制非同步HTTP請求的併發量,確保在任何給定時間內不超過20個網頁同時下載。`ParallelOptions`不適用於非同步操作,但可考慮使用`Parallel.ForEach`,儘管在非同步場景中謹慎使用。 對於併發非同步 I/O 操作的數量 ...
  • 1.Linux上安裝Docken 伺服器系統版本以及內核版本:cat /etc/redhat-release 查看伺服器內核版本:uname -r 安裝依賴包:yum install -y yum-utils device-mapper-persistent-data lvm2 設置阿裡雲鏡像源:y ...
  • 概述:WPF界面綁定和渲染大量數據可能導致性能問題。通過啟用UI虛擬化、非同步載入和數據分頁,可以有效提高界面響應性能。以下是簡單示例演示這些優化方法。 在WPF中,當你嘗試綁定和渲染大量的數據項時,性能問題可能出現。以下是一些可能導致性能慢的原因以及優化方法: UI 虛擬化: WPF提供了虛擬化技術 ...
  • 引言 上一章節介紹了 TDD 的三大法則,今天我們講一下在單元測試中模擬對象的使用。 Fake Fake - Fake 是一個通用術語,可用於描述 stub或 mock 對象。 它是 stub 還是 mock 取決於使用它的上下文。 也就是說,Fake 可以是 stub 或 mock Mock - ...
  • 為.net6在CentOS7上面做準備,先在vmware虛擬機安裝CentOS 7.9 新建CentOS764位的系統 因為CentOS8不更新了,所以安裝7;簡單就一筆帶過了 選擇下載好的操作系統的iso文件,下載地址https://mirrors.aliyun.com/centos/7.9.20 ...
  • 經過前面幾篇的學習,我們瞭解到指令的大概分類,如:參數載入指令,該載入指令以 Ld 開頭,將參數載入到棧中,以便於後續執行操作命令。參數存儲指令,其指令以 St 開頭,將棧中的數據,存儲到指定的變數中,以方便後續使用。創建實例指令,其指令以 New 開頭,用於在運行時動態生成並初始化對象。方法調用指... ...
  • LiteDB 是一個輕量級的嵌入式 NoSQL 資料庫,其設計理念與 MongoDB 類似,但它是完全使用 C# 開發的,因此與 C# 應用程式的集成非常順暢。與 SQLite 相比,LiteDB 提供了 NoSQL(即鍵值對)的數據存儲方式,並且是一個開源且免費的項目。它適用於桌面、移動以及 We ...
  • 1 開源解析和拆分文檔 第三方的工具去對文件解析拆分,去將我們的文件內容給提取出來,並將我們的文檔內容去拆分成一個小的chunk。常見的PDF word mark down, JSON、HTML。都可以有很好的一些模塊去把這些文件去進行一個東西去提取。 優勢 支持豐富的文檔類型 每種文檔多樣化選擇 ...
  • OOM是什麼?英文全稱為 OutOfMemoryError(記憶體溢出錯誤)。當程式發生OOM時,如何去定位導致異常的代碼還是挺麻煩的。 要檢查OOM發生的原因,首先需要瞭解各種OOM情況下會報的異常信息。這樣能縮小排查範圍,再結合異常堆棧、heapDump文件、JVM分析工具和業務代碼來判斷具體是哪 ...