.NET 4.0 Beta 2改進(jìn)對協(xié)調(diào)數(shù)據(jù)結(jié)構(gòu)類庫
對于.NET 4.0 Beta 2,大家可能還處于試用階段,本文將討論的是.NET 4.0 Beta 2改進(jìn)對協(xié)調(diào)數(shù)據(jù)結(jié)構(gòu)類庫,希望對大家有所幫助。
協(xié)調(diào)數(shù)據(jù)結(jié)構(gòu)(Coordination Data Structures,CDS)被設(shè)計為在并發(fā)環(huán)境下使用的組件,它也可用于構(gòu)建復(fù)雜的并發(fā)框架。此外,它還包含了高級的同步工具,如Barrier,多種線程安全的集合,以及多種構(gòu)建Future模型的方式。
#T#
Barrier類的作用是在多個階段的操作之間創(chuàng)建同步點(diǎn)。在使用之前,Barrier需要知道有多少線程將會使用它。每個線程達(dá)到檢查點(diǎn)時,便要調(diào)用Barrier的SignalAndWait方法。這么做會引起阻塞,當(dāng)所有線程都調(diào)用了這個方法后,便會同時釋放所有線程。這個過程可以重復(fù)多次,每個這樣的迭代都會增加其CurrentPhaseNumber屬性。用于監(jiān)控的代碼可以隨時檢查正在使用Barrier的線程,以及還沒有到達(dá)檢查點(diǎn)的線程數(shù)量。CurrentPhaseNumber為Int64類型,因此每個Barrier可以支持多達(dá)9,223,372,036,854,775,807個階段(之前的beta版本使用Int32,因此受限于40億個階段)。
BlockingCollection類用于生產(chǎn)者/消費(fèi)者場景。它最簡單的使用模式便是作為一個線程安全的隊列,并且在隊列為空時阻塞消費(fèi)者。為了避免隊列元素過多,你也可以為它設(shè)置一個最大值。在到達(dá)最大容量時,生產(chǎn)者便會被阻塞,直到某個消費(fèi)者取出元素。當(dāng)BlockingCollection填充完畢之后,生產(chǎn)者可以將其標(biāo)記為完成。這樣便無法添加更多的元素,同時也會釋放了所有的消費(fèi)者。
BlockingCollection并非只能單獨(dú)使用,多個 BlockingCollection可以一起使用。在這種模式下,生產(chǎn)者和消費(fèi)者可以指明為任意一個BlockingCollection添加或刪除元素,而不在乎某個特定的集合。這么做可以充分在集合之間的實(shí)現(xiàn)某種負(fù)載均衡。
ConcurrentDictionary類支持原子性的添加和更新操作。為了實(shí)現(xiàn)這個功能,你需要向GetOrAdd及AddOrUpdate方法中傳入一個委托。如果當(dāng)前鍵不在集合中便會調(diào)用Add委托。如果鍵存在,那么便會返回對應(yīng)的值,或是將其傳遞給Update委托。
原本還有計劃實(shí)現(xiàn)一個并行鏈表,但是這點(diǎn)在beta 2中被取消了。Joshua Phillips寫到,他們無法為這個類在性能和可用性之間做出平衡:
在每個軟件專業(yè)人士的職業(yè)生涯中,總會遇到某些情況需要放棄他們所鐘愛的東西。他們的發(fā)明雖然很棒,但總會有這樣那樣的原因,導(dǎo)致這些東西失去存在的充分價值。我知道你們對Beta 1中的ConcurrentLinkedList
對于需要延遲執(zhí)行的函數(shù),目前有了兩個選擇。如果你想使用future模型來傳遞那些只在需要時才調(diào)用的函數(shù),那么可以使用Lazy類。這個類封裝了一個函數(shù),保證它只在第一次訪問Value屬性的時候才執(zhí)行,以后對于Value屬性的多次訪問不會引起函數(shù)的重復(fù)調(diào)用。
第二個選項則是LazyInitializer模塊。EnsureInitialized方法是一個保證初始化完成的輕量級做法,它在(且僅在)目標(biāo)變量為null的情況才調(diào)用委托。這保證了目標(biāo)變量只會設(shè)置一次。不過,如果沒有使用同步對象的話,委托可能會被幾個并發(fā)線程調(diào)用多次。