深入多線程之:深入分析Interlocked
在大多數(shù)計算機上,增加變量操作不是一個原子操作,需要執(zhí)行下列步驟:
一:將實例變量中的值加載到寄存器中。
二:增加或減少該值。
三:在實例變量中存儲該值。
在多線程環(huán)境下,線程會在執(zhí)行完前兩個步驟后被搶先。然后由另一個線程執(zhí)行所有三個步驟,當?shù)谝粋€線程重新開始執(zhí)行時,它覆蓋實例變量中的值,造成第二個線程執(zhí)行增減操作的結果丟失。
Interlocked可以為多個線程共享的變量提供原子操作。
Interlocked.Increment:以原子操作的形式遞增指定變量的值并存儲結果。
Interlocked.Decrement以原子操作的形式遞減指定變量的值并存儲結果。
Interlocked.Add以原子操作的形式,添加兩個整數(shù)并用兩者的和替換第一個整數(shù)
但是Interlocked并沒有為乘法,除法提供原子操作。那么如何實現(xiàn)乘法,除法,以及為其他的一些非原子操作提供原子操作的支持呢??
關鍵就在于Interlocked.CompareExchange 中,Jeffrey Richter把它叫做InterLocked Anything 模式。
下面我們使用Interlocked.CompareExchange 實現(xiàn)求最大值的原子操作。
public static int Maximum(ref int target, int value)
{
int currentVal = target; //將target的當前值保存到currentVal中
int startVal, desiredVal; //聲明兩個變量來記錄操作開始前的值和期望的結果值。
do
{
startVal = currentVal; //將currentVal中的值保存到startVal中,此時記錄的是target在操作開始前的最初值。
desiredVal = Math.Max(startVal, value); //通過startVal進行復雜的計算,返回一個期望的結果,在這里僅僅是返回兩者的最大值。
//線程可能在這里被搶占,target的值可能被改變
//如果target的值被改變了,那么target和startVal的值就不想等,所以就不應該用desiredVal替換target.
//如果target的值沒有被改變,那么target和startVal的值就像等,使用desiredVal替換target.
//不管替換或者不替換,CompareExchange的返回值始終是target的值,所以currentVal的值現(xiàn)在是target的最新值。
//CompareExchange:將target和startVal的值比較,相等則用desiredVal替換,否則不操作,
//不管替換還是不替換返回的都是原來保存在target的值。
currentVal = Interlocked.CompareExchange(ref target, desiredVal, startVal);
} while (startVal != currentVal); //當target的起始值和最新值不相等的時候,說明target被修改了,所以繼續(xù)下次判斷,否則退出循環(huán)。
return desiredVal;
}
這段代碼的核心就是:currentVal = Interlocked.CompareExchange(ref target, desiredVal, startVal);
// 將target的值和startVal的值比較,相等則用desiredVal替換target,否則不操作,
//不管替換還是不替換返回的都是原來保存在target的值。
在這里,計算可能會比較復雜,而不像上面的Math.Max一樣,所以可以使用委托調(diào)用的方式進行封裝。
delegate int Morpher<TResult, TArgument>(int startValue, TArgument argument,
out TResult morphResult);
static TResult Morph<TResult, TArgument>(ref int target, TArgument argument,
Morpher<TResult, TArgument> morpher)
{
TResult morphResult;
int currentVal = target, startVal, desiredVal;
do
{
startVal = currentVal;
desiredVal = morpher(startVal, argument, out morphResult);
currentVal = Interlocked.CompareExchange(ref target, desiredVal, startVal);
} while (startVal != currentVal);
return morphResult;
}
基本原理和上面的一致。
相關文章
C# System.BadImageFormatException問題及解決
這篇文章主要介紹了C# System.BadImageFormatException問題及解決方案,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教2024-05-05
C#創(chuàng)建及訪問網(wǎng)絡硬盤的實現(xiàn)
本文主要介紹了C#創(chuàng)建及訪問網(wǎng)絡硬盤的實現(xiàn),文中通過示例代碼介紹的非常詳細,具有一定的參考價值,感興趣的小伙伴們可以參考一下2022-03-03
Winform中Treeview實現(xiàn)按需加載的方法
這篇文章主要介紹了Winform中Treeview實現(xiàn)按需加載的方法,針對大數(shù)據(jù)量的情況下非常具有實用價值,需要的朋友可以參考下2014-10-10
c#中l(wèi)ist.FindAll與for循環(huán)的性能對比總結
這篇文章主要給大家總結介紹了關于c#中l(wèi)ist.FindAll與for循環(huán)的性能,文中通過詳細的示例代碼給大家介紹了這兩者之間的性能,對大家的學習或工作具有一定的參考學習價值,需要的朋友們下面來一起學習學習吧。2017-10-10

