国产探花免费观看_亚洲丰满少妇自慰呻吟_97日韩有码在线_资源在线日韩欧美_一区二区精品毛片,辰东完美世界有声小说,欢乐颂第一季,yy玄幻小说排行榜完本

首頁 > 編程 > C# > 正文

.NET中保證線程安全的高級(jí)方法Interlocked類使用介紹

2020-01-24 02:39:54
字體:
供稿:網(wǎng)友

說到線程安全,不要一下子就想到加鎖,尤其是可能會(huì)調(diào)用頻繁或者是要求高性能的場合。

對于性能要求不高或者同步的對象數(shù)量不多的時(shí)候,加鎖是一個(gè)比較簡單而且易于實(shí)現(xiàn)的選擇。比方說.NET提供的一些基礎(chǔ)類庫,比如線程安全的堆棧和隊(duì)列,如果使用加鎖的方式那么會(huì)使性能大打折扣(速度可能會(huì)降低好幾個(gè)數(shù)量級(jí)),而且如果設(shè)計(jì)得不好的話還有可能發(fā)生死鎖。

現(xiàn)在通過查看微軟的源代碼來學(xué)習(xí)一些不直接lock(等價(jià)于Monitor類)的線程同步技巧吧。

這里我們主要用的是Interlocked類,這個(gè)類按照M$的描述,是“為多個(gè)線程共享的變量提供原子操作”,當(dāng)然這個(gè)類是一個(gè)靜態(tài)類。這個(gè)類的源代碼看不到,因?yàn)槭钦{(diào)用的CLR內(nèi)部的方法,不過基本思想應(yīng)該是通過硬件原語try and set來實(shí)現(xiàn)的。

該類提供的Add、Increment、Decrement能夠完成簡單的原子操作。

假如我們要提供一個(gè)計(jì)數(shù)器,每訪問一次就遞增地返回一個(gè)新的數(shù)值用于計(jì)數(shù)。在多線程環(huán)境下,s++這一條語句不是線程安全的。因?yàn)閳?zhí)行這個(gè)語句要經(jīng)過:移到寄存器(讀取)、運(yùn)算、寫入這幾個(gè)步驟,在任何時(shí)候都可能會(huì)切換到其他線程,這樣子s被多個(gè)線程訪問值可能會(huì)在切換的過程中丟失。有了Interlocked提供的這幾個(gè)原子操作的方法,就不用自己去加鎖實(shí)現(xiàn)這些簡單的運(yùn)算了。由于是使用的硬件原語,其效率自然也比加鎖高得多。

但是大多數(shù)情況下,問題并沒有執(zhí)行相加相減運(yùn)算那么簡單,這時(shí)如果不想用鎖的話就要想想辦法了。

以微軟的ConcurrentStack提供的線程安全的堆棧為例,分析一下如何實(shí)現(xiàn)如果往棧頭添加數(shù)據(jù)。

m_head是指向堆頂?shù)闹羔槪诙x的時(shí)候由于是多線程訪問的,所以要加上volatile修飾符:

復(fù)制代碼 代碼如下:

private volatile Node m_head;

如果是單線程的,那么入棧語句就是下面這個(gè)樣子:

復(fù)制代碼 代碼如下:

1.    Node newNode = new Node(item);
2.    newNode.m_next = m_head;
3.    m_head = newNode;

假如有兩個(gè)線程并發(fā)訪問入棧方法的話,那么可能會(huì)產(chǎn)生如下情況:第一個(gè)線程執(zhí)行完第二條語句被打斷,第二個(gè)線程執(zhí)行到第二條語句又切換回第一個(gè)線程,兩個(gè)線程執(zhí)行完后有一個(gè)入棧的元素就不見了。那么如何實(shí)現(xiàn)線程安全呢?M$的代碼是這樣寫的:

復(fù)制代碼 代碼如下:

Node newNode = new Node(item);
newNode.m_next = m_head;
if (Interlocked.CompareExchange(ref m_head, newNode, newNode.m_next) == newNode.m_next)
{
    return;
}

// If we failed, go to the slow path and loop around until we succeed.
PushCore(newNode, newNode);


首先,Interlocked.CompareExchange比較兩個(gè)元素是否相等,并根據(jù)比較的結(jié)果替換其中一個(gè)元素,返回結(jié)果始終是第一個(gè)元素的原值。這個(gè)方法是原子操作。

那么這段代碼首先設(shè)置newNode的下一節(jié)點(diǎn)為堆棧頂部的元素,接下來CompareExchange,判斷棧頂元素有沒有被修改過。假如此時(shí)沒有另一個(gè)線程修改棧頂元素,那么m_head還是原來的值(上一條語句設(shè)置的新棧頂?shù)南乱粋€(gè)元素),此時(shí)就可以安全地把棧頂指針指向新元素,操作完成(return)。注意CompareExchange是原子操作的,所以在這期間棧頂元素不可能再被修改。

如果比較結(jié)果不相等,那么說明棧頂元素已經(jīng)被其他線程修改了(此時(shí)返回值就是被修改后的棧頂,和上一條語句設(shè)置m_next不一樣),這樣CompareExchange就不會(huì)修改m_head,說明入棧不成功,執(zhí)行PushCore方法。


這個(gè)東東的代碼如下:

復(fù)制代碼 代碼如下:

        private void PushCore(Node head, Node tail)
        {
            SpinWait spin = new SpinWait();

            // Keep trying to CAS the exising head with the new node until we succeed.
            do
            {
                spin.SpinOnce();
                // Reread the head and link our new node.
                tail.m_next = m_head;
            }
            while (Interlocked.CompareExchange(
                ref m_head, head, tail.m_next) != tail.m_next);

#if !FEATURE_PAL && !FEATURE_CORECLR
            if (CDSCollectionETWBCLProvider.Log.IsEnabled())
            {
                CDSCollectionETWBCLProvider.Log.ConcurrentStack_FastPushFailed(spin.Count);
            }
#endif //!FEATURE_PAL && !FEATURE_CORECLR
        }


可以看到其邏輯還是和上面那個(gè)一樣,只是加了一個(gè)循環(huán)直到操作完成。在這期間使用了一個(gè)SpinWait對象和SpinOnce方法,那么我們又要了解一下這是干嘛的。

關(guān)于SpinWait對象,M$的說明是:System.Threading.SpinWait 是一個(gè)輕量同步類型,可以在低級(jí)別方案中使用它來避免內(nèi)核事件所需的高開銷的上下文切換和內(nèi)核轉(zhuǎn)換。

關(guān)于它的說明還有一堆,你可以參考這里。如果不想看那么多,那么只需了解它的使用場合是在資源不會(huì)被占用很長時(shí)間的時(shí)候進(jìn)行等待,以用戶模式自旋以避免高額的開銷。

SpinOnce的說明很簡單,就是執(zhí)行單一自旋,可以理解為等待一個(gè)很短的時(shí)間。總的來說,當(dāng)自旋此時(shí)達(dá)到5次時(shí),會(huì)切換到同一處理器上的另一個(gè)線程,當(dāng)達(dá)到20次時(shí),會(huì)調(diào)用Thread的Sleep方法阻塞當(dāng)前線程,此時(shí)可以切換到其他同優(yōu)先級(jí)或更高優(yōu)先級(jí)的線程上去。

這樣,就可以避免加鎖(lock free)的高昂代價(jià)來實(shí)現(xiàn)線程的同步。

但是有的時(shí)候我們不能保證線程安全。比如堆棧的Count屬性,在程序調(diào)用這個(gè)屬性后,我們并不能保證這個(gè)屬性返回的時(shí)候是正確的,在返回到應(yīng)用程序的線程前元素?cái)?shù)量是有可能變化的,因此我們也就只能保證我們的返回值曾經(jīng)正確。

不過顯而易見,這是可以接受的。對于開發(fā)者來說,假如我們要訪問一個(gè)多線程字典(ConcurrentDictionary)中的指定元素,我們不應(yīng)該是先判斷是否為空再取元素(因?yàn)樵乜赡茉谶@兩步操作之間被刪掉),而是應(yīng)該使用TryGetValue這種保證線程安全的方法來進(jìn)行操作。

發(fā)表評(píng)論 共有條評(píng)論
用戶名: 密碼:
驗(yàn)證碼: 匿名發(fā)表
主站蜘蛛池模板: 杨浦区| 栾城县| 霍林郭勒市| 白银市| 仲巴县| 微博| 新竹县| 德钦县| 平武县| 凉城县| 孟津县| 中山市| 洪雅县| 娄烦县| 富川| 吴忠市| 略阳县| 武鸣县| 安阳县| 南昌县| 遵化市| 兴文县| 新巴尔虎左旗| 双牌县| 宜兰市| 高要市| 灵璧县| 永川市| 阿图什市| 洪湖市| 科尔| 襄城县| 双桥区| 静乐县| 德州市| 石台县| 德昌县| 拜泉县| 揭阳市| 新乡县| 潼南县|