C#使用CallContext緩存線程數(shù)據(jù)
一、CallContext 概述
命名空間:System.Runtime.Remoting.Messaging
CallContext 用于提供與執(zhí)行代碼路徑一起傳送的屬性集,直白講就是:提供線程(多線程/單線程)代碼執(zhí)行路徑中數(shù)據(jù)傳遞的能力。
當(dāng)對(duì)另一個(gè) AppDomain 中的對(duì)象進(jìn)行遠(yuǎn)程方法調(diào)用時(shí),CallContext 類將生成一個(gè)與該遠(yuǎn)程調(diào)用一起傳播的 LogicalCallContext 實(shí)例。只有公開(kāi) ILogicalThreadAffinative 接口并存儲(chǔ)在 CallContext 中的對(duì)象被在 LogicalCallContext 中傳播到 AppDomain 外部。
CallContext成員
- SetData: 存儲(chǔ)給定的對(duì)象并將其與指定名稱關(guān)聯(lián)。
- GetData: 從CallContext中檢索具有指定名稱的對(duì)象
- LogicalSetData: 將給定的對(duì)象存儲(chǔ)在邏輯調(diào)用上下文,并將其與指定名稱關(guān)聯(lián)??捎糜诙嗑€程環(huán)境
- LogicalGetData: 從邏輯調(diào)用上下文中檢索具有指定名稱的對(duì)象??捎糜诙嗑€程環(huán)境
- FreeNamedDataSlot: 清空具有指定名稱的數(shù)據(jù)槽??捎糜诙嗑€程環(huán)境
- HostContext屬性: 獲取或設(shè)置與當(dāng)前線程相關(guān)聯(lián)的主機(jī)上下文。在Web環(huán)境下等于System.Web.HttpContext.Current
GetData、SetData
只能用于單線程環(huán)境,如果發(fā)生了線程切換,存儲(chǔ)的數(shù)據(jù)也會(huì)隨之丟失
可以用于同一線程中的不同地方,傳遞數(shù)據(jù)
LogicalSetData、LogicalGetData
- LogicalSetData、LogicalGetData可用于在多線程環(huán)境下傳遞數(shù)據(jù);
- LogicalSetData只是存儲(chǔ)當(dāng)前線程以及子線程的數(shù)據(jù)槽
- LogicalGetData獲取的是當(dāng)前線程或父線程的數(shù)據(jù)槽對(duì)象,拿到的是對(duì)象的引用
- FreeNamedDataSlot清除當(dāng)前線程,之前已經(jīng)運(yùn)行子任務(wù),不受影響,不能清除子線程的數(shù)據(jù)槽;
二、 CallContext不跨線程傳播的方法:GetData、SetData
可以利用CallContext 實(shí)現(xiàn)單例,默認(rèn)情況下,CallContext 的數(shù)據(jù)不跨線程傳播。
1、在處理多組件共用Context時(shí)非常有用,比如常見(jiàn)的EF 可以將實(shí)例的DBEntity存儲(chǔ)在其中,可以一次訪問(wèn)只實(shí)例化一次,便于管理且不用多次實(shí)例訪問(wèn)對(duì)象
public static class DbContextHelper { private static DbContext context = null; private const string SessionKey_DbContext = "Entities"; public static DbContext GetDbContext() { if (CallContext.GetData(SessionKey_DbContext) == null) { CallContext.SetData(SessionKey_DbContext, new Entities()); } return CallContext.GetData(SessionKey_DbContext) as Entities; } }
2、類單例
void Main() { MyAppContext.Current.FirstName = "a"; Console.Write(MyAppContext.Current.FirstName); } public class MyAppContext { const string contextKey = "MyAppContext:ContextKey"; public string FirstName { get; set; } public static MyAppContext Current { get { if (CallContext.GetData(contextKey) == null) { CallContext.SetData(contextKey, new MyAppContext()); } return CallContext.GetData(SessionKey_DbContext) as MyAppContext; } } }
三、 CallContext跨線程傳播的方法:ILogicalSetData、LogicalGetData
要讓CallContext實(shí)現(xiàn)跨線程傳播,可以調(diào)用CallContext的靜態(tài)方法ILogicalSetData,或讓上下文類實(shí)現(xiàn)ILogicalThreadAffinative 接口。
線程本地存儲(chǔ)
線程池可能不會(huì)釋放使用過(guò)的線程,導(dǎo)致多次執(zhí)行之間可能共享數(shù)據(jù)(可以每次執(zhí)行前重置線程本地存儲(chǔ)的數(shù)據(jù))。
for (var i = 0; i < 10; i++) { Thread.Sleep(10); Task.Run(() => { var slot = Thread.GetNamedDataSlot("test"); if (slot == null) { Thread.AllocateNamedDataSlot("test"); } if (Thread.GetData(slot) == null) { Thread.SetData(slot, DateTime.Now.Millisecond); } Console.WriteLine(Thread.CurrentThread.ManagedThreadId + ":" + Thread.GetData(slot)); }); }
結(jié)果
調(diào)用上下文
每次執(zhí)行的數(shù)據(jù)是完全隔離的,非常符合我們的期望。但是,如果我們期望調(diào)用期間又開(kāi)啟了一個(gè)子線程,如何讓子線程訪問(wèn)父線程的數(shù)據(jù)呢?這就需要使用到:“邏輯調(diào)用上下文”。
Console.WriteLine("測(cè)試:CallContext.SetData"); for (var i = 0; i < 10; i++) { Thread.Sleep(10); Task.Run(() => { if (CallContext.GetData("test") == null) { CallContext.SetData("test", DateTime.Now.Millisecond); } Console.WriteLine(Thread.CurrentThread.ManagedThreadId + ":" + CallContext.GetData("test")); }); }
結(jié)果
每次執(zhí)行的數(shù)據(jù)是完全隔離的,非常符合我們的期望。
邏輯調(diào)用上下文
如果我們期望調(diào)用期間又開(kāi)啟了一個(gè)子線程,如何讓子線程訪問(wèn)父線程的數(shù)據(jù)呢?這就需要使用到:“邏輯調(diào)用上下文”。
注意 ExecutionContext.SuppressFlow(); 和ExecutionContext.RestoreFlow();它們分別能阻止傳播和重置傳播,默認(rèn)是允許傳播的。
Console.WriteLine("測(cè)試:CallContext.SetData"); Task.Run(() => { CallContext.SetData("test", "段光偉"); Console.WriteLine(Thread.CurrentThread.ManagedThreadId + ":" + CallContext.GetData("test")); Task.Run(() => { Console.WriteLine(Thread.CurrentThread.ManagedThreadId + ":" + CallContext.GetData("test")); }); }); Thread.Sleep(100); Console.WriteLine("測(cè)試:CallContext.LogicalSetData"); Task.Run(() => { CallContext.LogicalSetData("test", "段光偉"); Console.WriteLine(Thread.CurrentThread.ManagedThreadId + ":" + CallContext.LogicalGetData("test")); Task.Run(() => { Console.WriteLine(Thread.CurrentThread.ManagedThreadId + ":" + CallContext.LogicalGetData("test")); }); ExecutionContext.SuppressFlow(); Task.Run(() => { Console.WriteLine("SuppressFlow 之后:" + CallContext.LogicalGetData("test")); }); ExecutionContext.RestoreFlow(); Task.Run(() => { Console.WriteLine("RestoreFlow 之后:" + CallContext.LogicalGetData("test")); }); });
輸出
四、Web中的CallContext
HttpContext.Current(包括Session)的存儲(chǔ)是基于當(dāng)前線程的CallContext,在非請(qǐng)求處理線程(即其他線程)是無(wú)法獲取當(dāng)前HttpContext的(不跨線程傳播)。
到此這篇關(guān)于C#使用CallContext緩存線程數(shù)據(jù)的文章就介紹到這了。希望對(duì)大家的學(xué)習(xí)有所幫助,也希望大家多多支持腳本之家。
相關(guān)文章
分享兩種實(shí)現(xiàn)Winform程序的多語(yǔ)言支持的多種解決方案
本篇文章主要介紹了分享兩種實(shí)現(xiàn)Winform程序的多語(yǔ)言支持的多種解決方案,小編覺(jué)得挺不錯(cuò)的,現(xiàn)在分享給大家,也給大家做個(gè)參考。一起跟隨小編過(guò)來(lái)看看吧。2017-02-02WPF/Silverlight實(shí)現(xiàn)圖片局部放大的方法分析
這篇文章主要介紹了WPF/Silverlight實(shí)現(xiàn)圖片局部放大的方法,結(jié)合實(shí)例形式分析了WPF/Silverlight針對(duì)圖片屬性操作相關(guān)實(shí)現(xiàn)技巧,需要的朋友可以參考下2017-03-03C#實(shí)現(xiàn)JSON和對(duì)象之間互相轉(zhuǎn)換功能示例
這篇文章主要介紹了C#實(shí)現(xiàn)JSON和對(duì)象之間互相轉(zhuǎn)換功能,結(jié)合實(shí)例形式較為詳細(xì)的分析了C#實(shí)現(xiàn)對(duì)象與json之間相互轉(zhuǎn)換的操作技巧,需要的朋友可以參考下2017-09-09C# Winform實(shí)現(xiàn)截圖工具的示例代碼
這篇文章主要為大家詳細(xì)介紹了如何使用C# Winform制作一個(gè)簡(jiǎn)單的截圖工具,從而實(shí)現(xiàn)截圖功能,文中的示例代碼講解詳細(xì),有需要的可以參考下2024-02-02