多線程共用變數和 AsyncLocal

来源:https://www.cnblogs.com/BigBrotherStone/archive/2020/02/16/12317086.html

" 返回《C 併發編程》" "1. 簡介" "2. 非同步下的共用變數" "3. 解析 AsyncLocal" "3.1. IAsyncLocalValueMap 的實現" "3.2. 結論" 1. 簡介 + 普通 共用變數: + 在某個類上用靜態屬性的方式即可。 + 多線程 共用變數 + 希望能將這 ...


>>返回《C# 併發編程》

1. 簡介

  • 普通共用變數:
    • 在某個類上用靜態屬性的方式即可。
  • 多線程共用變數
    • 希望能將這個變數的共用範圍縮小到單個線程
    • 無關係的B線程無法訪問到A線程的值;

[ThreadStatic]特性、ThreadLocal<T>CallContextAsyncLocal<T> 都具備這個特性。

例子:

由於 .NET Core 不再實現 CallContext,所以下列代碼只能在 .NET Framework 中執行

class Program
{
    //對照
    private static string _normalStatic;

    [ThreadStatic]
    private static string _threadStatic;
    private static ThreadLocal<string> _threadLocal = new ThreadLocal<string>();
    private static AsyncLocal<string> _asyncLocal = new AsyncLocal<string>();
    static void Main(string[] args)
    {
        Parallel.For(0, 4, _ =>
        {
            var threadId = Thread.CurrentThread.ManagedThreadId;

            var value = $"這是來自線程{threadId}的數據";
            
            _normalStatic = value;
            _threadStatic = value;
            CallContext.SetData("value", value);
            _threadLocal.Value = value;
            _asyncLocal.Value = value;
            
            Console.WriteLine($"Use Normal;                Thread:{threadId}; Value:{_normalStatic}");
            Console.WriteLine($"Use ThreadStaticAttribute; Thread:{threadId}; Value:{_threadStatic}");
            Console.WriteLine($"Use CallContext;           Thread:{threadId}; Value:{CallContext.GetData("value")}");
            Console.WriteLine($"Use ThreadLocal;           Thread:{threadId}; Value:{_threadLocal.Value}");
            Console.WriteLine($"Use AsyncLocal;            Thread:{threadId}; Value:{_asyncLocal.Value}");
        });

        Console.Read();
    }
}

輸出:

Use Normal;                Thread:15; Value:10
Use [ThreadStatic];        Thread:15; Value:15
Use Normal;                Thread:10; Value:10
Use Normal;                Thread:8; Value:10
Use [ThreadStatic];        Thread:8; Value:8
Use CallContext;           Thread:8; Value:8
Use [ThreadStatic];        Thread:10; Value:10
Use CallContext;           Thread:10; Value:10
Use CallContext;           Thread:15; Value:15
Use ThreadLocal;           Thread:15; Value:15
Use ThreadLocal;           Thread:8; Value:8
Use AsyncLocal;            Thread:8; Value:8
Use ThreadLocal;           Thread:10; Value:10
Use AsyncLocal;            Thread:10; Value:10
Use AsyncLocal;            Thread:15; Value:15

結論:

  • Normal 為對照組
  • Nomal 的 Thread 與 Value 值不同,因為讀到了其他線程修改的值
  • 其他的類型,存儲的值,在 Parallel 啟動的線程間是隔離的

2. 非同步下的共用變數

日常開發過程中,我們經常遇到非同步的場景。

非同步可能會導致代碼執行線程的切換。

例如:

測試:[ThreadStatic]特性、ThreadLocal<T>AsyncLocal<T> ,三種共用變數被非同步代碼賦值後的表現。

class Program
{
    [ThreadStatic]
    private static string _threadStatic;
    private static ThreadLocal<string> _threadLocal = new ThreadLocal<string>();
    private static AsyncLocal<string> _asyncLocal = new AsyncLocal<string>();
    static void Main(string[] args)
    {
        _threadStatic = "set";
        _threadLocal.Value = "set";
        _asyncLocal.Value = "set";
        PrintValuesInAnotherThread();
        Console.ReadKey();
    }

    private static void PrintValuesInAnotherThread()
    {
        Task.Run(() =>
        {
            Console.WriteLine($"ThreadStatic: {_threadStatic}");
            Console.WriteLine($"ThreadLocal: {_threadLocal.Value}");
            Console.WriteLine($"AsyncLocal: {_asyncLocal.Value}");
        });
    }
}

輸出:

ThreadStatic: 
ThreadLocal: 
AsyncLocal: set

結論:

在非同步發生後,線程被切換,只有 AsyncLocal 還能夠保留原來的值.

  • CallContext 也可以實現這個需求,但 .Net Core 沒有被實現,這裡就不過多說明。

我們總結一下這些變數的表現:

實現方式 DotNetFx DotNetCore 是否支持數據向輔助線程的
[ThreadStatic]
ThreadLocal
CallContext.SetData(string name, object data) 僅當參數 data 對應的類型實現了 ILogicalThreadAffinative 介面時支持
CallContext.LogicalSetData(string name, object data)
AsyncLocal

輔助線程: 用於處理後臺任務,用戶不必等待就可以繼續使用應用程式,比如線程池線程。

註意:

  • [ThreadStatic]特性、ThreadLocal<T> 最好不要用在線程池線程
    • 線程池線程是可重用的,線程不會銷毀,當線程被重用時,之前使用保存的值依然存在,可能造成影響
  • 使用 AsyncLocal<T> 可以用線上程池線程
    • 線程使用後回歸線程池, AsyncLocal<T> 的狀態會被清除,無法訪問之前的值
  • new Task(...) 預設不是新建一個線程,而是使用線程池線程

3. 解析 AsyncLocal

  • AsyncLocal<T>Value 屬性的真正的數據存取是通過 ExecutionContextinternal 的方法 GetLocalValueSetLocalValue 將數據存到 當前ExecutionContext 上的 m_localValues 欄位上
    • ExecutionContext 會根據執行環境進行流動,詳見 《ExecutionContext(執行上下文)綜述》
    • 簡單描述就是,線程發生切換的時候, ExecutionContext 會在前一個線程中被捕獲,流向下一個線程,它所保存的數據也就隨之流動了
      • 在所有會發生線程切換的地方,基礎類庫(BCL) 都為我們封裝好了對 ExecutionContext 的捕獲
      • 例如:
        • new Thread(...).Start()
        • new Task(...).Start()
        • Task.Run(...)
        • ThreadPool.QueueUserWorkItem(...)
        • await 語法糖
  • m_localValues 類型是 IAsyncLocalValueMap

3.1. IAsyncLocalValueMap 的實現

以下為基礎設施提供的實現:

類型 元素個數
EmptyAsyncLocalValueMap 0
OneElementAsyncLocalValueMap 1
TwoElementAsyncLocalValueMap 2
ThreeElementAsyncLocalValueMap 3
MultiElementAsyncLocalValueMap 4 ~ 16
ManyElementAsyncLocalValueMap > 16

隨著 ExecutionContext 所關聯的 AsyncLocal 數量的增加, IAsyncLocalValueMap實現將會在 ExecutionContextSetLocalValue 方法中被不斷替換

  • 查詢的時間複雜度和空間複雜度依次遞增

3.2. 結論

  • AsyncLocal 類型存儲數據,是在自己線程的 ExecutionContext
  • ExecutionContext 的實例會隨著非同步或者多線程的啟動而被流向執行後續代碼的其他線程,保證了啟動非同步的線程存儲的數據可以被訪問到
  • 數據存到 IAsyncLocalValueMap 類型的變數中,此變數會根據存儲的 AsyncLocal 變數個數而切換實現
    • 支持存儲量越大的實現類型,性能越

參考資料
《淺析 .NET 中 AsyncLocal 的實現原理》 --- 黑洞視界


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

更多相關文章
  • 併發編程之無鎖 6.2 CAS與volatile 源碼之LongAdder 6.8 Unsafe 6.2 CAS與volatile 其中的關鍵是compareAndSet,它的簡稱就是CAS(也有Compare And Swap的說法),它必須是原子操作。註意其實CAS的底層是lock cmpxch ...
  • 這一篇討論了使用 const 、volatile 和 typedef 使變數更容易地使用 ...
  • 在Kubernetes中,通常kube schduler和kube controller manager都是多副本進行部署的來保證高可用,而真正在工作的實例其實只有一個。這裡就利用到 的選主機制,保證leader是處於工作狀態,並且在leader掛掉之後,從其他節點選取新的leader保證組件正常工 ...
  • 前言 這兩天一番花兩天的時間,重新用python和python圖形化開發工具tkinter,完善了下PDF合併小工具,終於可以發佈了。 工具目前基本功能已經完善,後期如果有反饋可以修複部分bug或完善需求。 這個工具基本具備了一個面向大眾的特性,只要是windows用戶,都可以很容易使用。 PDF合 ...
  • 題目:將你的 QQ 頭像(或者微博頭像)右上角加上紅色的數字,類似於微信未讀信息數量那種提示效果。 類似於圖中效果: 代碼: 效果如下: 原圖: 輸出: 附一個Pillow庫的文檔:https://pillow.readthedocs.io/en/3.1.x/index.html ...
  • 前言 因為昨天重新研究了下python的打包方法,今天一番準備把之前寫的一個pdf合併軟體重新整理一下,打包出來。 但在打包的過程中仍然遇到了一些問題,半年前一番做打包的時候也遇到了一些問題,現在來看,解決這些問題思路清晰多了,這裡記錄下。 問題 打包成功,但運行時提示Failed to execu ...
  • 話不多說直接上代碼: // set添加單個元素 stopwatch.Start(); var isok = RedisCacheHelper.Instance.SetAdd("setkey", "10"); stopwatch.Stop(); Console.WriteLine("set添加單個元素 ...
  • 前面四章介紹了繼承自Shape的類,包括Rectangle、Ellipse、Polygon以及Polyline。但還有一個繼承自Shape的類尚未介紹,而且該類是到現在為止功能最強大的形狀類,即Path類。Path類能夠包含任何簡單形狀、多組形狀以及更複雜的要素,如曲線。 Path類提供了Data屬 ...
一周排行
  • 前幾天發佈了 "抄抄《CSS 故障藝術》的動畫" 這篇文章,在這篇文章里介紹瞭如何使用Win2D繪製文字然後配合BlendEffect製作故障藝術的動畫。本來打算就這樣收手不玩這個動畫了,但後來又發現性能不符合理想。明明只是做做Resize動畫和用BlendEffect混合,為什麼性能會這麼差呢? ...
  • 控制條控制項: progressBar 不能按照你程式的進程自動變化,需認為計算,調整變化量 private void progressBar1_Click(object sender, EventArgs e) { this.progressBar1.Maximum = 100;//設置進度條最大長 ...
  • 首先創建一個asp.net core web應用程式 第二步 目前官方預置了7種模板項目供我們選擇。從中我們可以看出,既有我們熟悉的MVC、WebAPI,又新添加了Razor Page,以及結合比較流行的Angular、React前端框架的模板項目。 空項目模板 Program.cs using S ...
  • 對閉包的理解 1.對於成員變數和局部變數:成員變數就是方法外部,類的內部定義的變數;局部變數就是方法或語句塊內部定義的變數。局部變數必須初始化。 形式參數是局部變數,局部變數的數據存在於棧記憶體中。棧記憶體中的局部變數隨著方法的消失而消失。成員變數存儲在堆中的對象裡面,由垃圾回收器負責回收。 成員變數它 ...
  • Xamarin.Forms讀取並展示Android和iOS通訊錄 TerminalMACS客戶端 本文同步更新地址: https://dotnet9.com/11520.html https://terminalmacs.com/861.html 閱讀導航: 一、功能說明 二、代碼實現 三、源碼獲取 ...
  • 做下對文件複製操作相關的筆記: /// <summary> /// 文件幫助類 /// </summary> public class FileHelper { /// <summary> /// 複製一個目錄下所有文件到一個新目錄下 /// </summary> /// <param name=" ...
  • 前言 有一個東西叫做鴨子類型,所謂鴨子類型就是,只要一個東西表現得像鴨子那麼就能推出這玩意就是鴨子。 C 裡面其實也暗藏了很多類似鴨子類型的東西,但是很多開發者並不知道,因此也就沒法好好利用這些東西,那麼今天我細數一下這些藏在編譯器中的細節。 不是只有 和 才能 在 C 中編寫非同步代碼的時候,我們經 ...
  • [toc] 1.應用背景 底端設備有大量網路報文(位元組數組):心跳報文,數據採集報文,告警報文上報。需要有對應的報文結構去解析這些位元組流數據。 2.結構體解析 由此,我第一點就想到了用結構體去解析。原因有以下兩點: 2.1.結構體存在棧中 類屬於引用類型,存在堆中;結構體屬於值類型,存在棧中,在一個 ...
  • 《深入淺出 C#》 (第3版) [作者] (美) Andrew Stellman (美) Jennifer Greene[譯者] (中) 徐陽 丁小峰 等譯[出版] 中國電力出版社[版次] 2016年08月 第1版[印次] 2018年04月 第4次 印刷[定價] 148.00元 【引子】 要學習編程 ...
  • 記錄使用對象初始值設定項初始化對象。 using System; using System.Collections.Generic; namespace ConsoleApp2 { class Program { static void Main(string[] args) { // 使用構造函數 ...
x