日韩无码专区无码一级三级片|91人人爱网站中日韩无码电影|厨房大战丰满熟妇|AV高清无码在线免费观看|另类AV日韩少妇熟女|中文日本大黄一级黄色片|色情在线视频免费|亚洲成人特黄a片|黄片wwwav色图欧美|欧亚乱色一区二区三区

RELATEED CONSULTING
相關(guān)咨詢
選擇下列產(chǎn)品馬上在線溝通
服務(wù)時(shí)間:8:30-17:00
你可能遇到了下面的問題
關(guān)閉右側(cè)工具欄

新聞中心

這里有您想知道的互聯(lián)網(wǎng)營(yíng)銷解決方案
分析.NET中的CountDownLatch類

最近筆者在用.Net寫程序時(shí)遇到一個(gè)問題:有N個(gè)互不相關(guān)的任務(wù)要在線程池中跑,但有一個(gè)線程要等待N個(gè)任務(wù)完成之后才能繼續(xù)。而這個(gè)N是個(gè)未知數(shù),可能會(huì) 很大(因此才會(huì)想到使用線程池而不是手動(dòng)去new一個(gè)therad)。翻了翻.Net類庫(kù)的文檔,發(fā)現(xiàn)一個(gè)叫WaitHandle的類。這個(gè)類的用法挺有 意思,需要為每個(gè)線程創(chuàng)建一個(gè)WaitHandle對(duì)象并把它們放在一個(gè)數(shù)組中,然后用WaitHandle類中的WaitAll方法來等待這些 WaitHandle被調(diào)用Set方法。(代碼就不寫了,可以參考MSDN http://msdn.microsoft.com/zh-cn/library /system.threading.waithandle.aspx)

我們提供的服務(wù)有:成都網(wǎng)站制作、做網(wǎng)站、微信公眾號(hào)開發(fā)、網(wǎng)站優(yōu)化、網(wǎng)站認(rèn)證、魏縣ssl等。為超過千家企事業(yè)單位解決了網(wǎng)站和推廣的問題。提供周到的售前咨詢和貼心的售后服務(wù),是有科學(xué)管理、有技術(shù)的魏縣網(wǎng)站制作公司

雖然覺得這有點(diǎn)復(fù)雜,但還是試了試。當(dāng)程序運(yùn)行時(shí),碰到了一個(gè)問 題,如果WaitHandle數(shù)組超過64個(gè)元素之后,WaitHandle對(duì)象的WatiAll方法罷工了。后來為了程序能運(yùn)行,只得想了一個(gè)笨辦法: 先創(chuàng)建兩個(gè)WaitHandle對(duì)象放在數(shù)組,然后用循環(huán)兩個(gè)兩個(gè)地運(yùn)行任務(wù)。代碼的思路大概是下面這樣:

WaitHandle[] handles = new WaitHandle[]{
    new AutoResetEvent(false),
    new AutoResetEvent(false)
};
int times = (int)N/2;
int i;
for(i = 0; i < times; i++){
    ThreadPool.QueueUserWorkItem(new WaitCallback(Tasks[i*2]), handles[0]);  
    ThreadPool.QueueUserWorkItem(new WaitCallback(Tasks[i*2+1]), handles[1]);
    WaitHandle.WaitAll(handles);
}
if(i*2 < N){
    ThreadPool.QueueUserWorkItem(new WaitCallback(Tasks[i*2 + 1]), handles[0]);
    WaitHandle.WaitAny(handles);
}

雖然代碼這么寫比較復(fù)雜,但至少可以保證運(yùn)行時(shí)不會(huì)出問題。但這么寫代碼顯然并不KISS!于是問了問高手,說有個(gè) RegisterWaitForSingleObject方法,但一看這個(gè)方法的參數(shù)列表就夠讓人暈的了。有點(diǎn)懷念Java了,記得Java中有個(gè) CountDownLatch類,創(chuàng)建類的時(shí)候賦一個(gè)初始值X,然后主線程中調(diào)用await,線程池中跑的線程調(diào)用countDown方法。就可以實(shí)現(xiàn)主 線程等待X次countDown方法調(diào)用之后繼續(xù)。這樣既沒有64個(gè)WaitHandle的限制,也不用去研究那個(gè) RegisterWaitForSingleObject方法。不過問題在于.Net中并沒有這么一個(gè)東西,只能自己動(dòng)手了。

class CountDownLatch {
    private object lockobj;
    private int counts;

    public CountDownLatch(int counts){
        this.counts = counts;
    }

    public void Await(){
        lock(lockobj){
            while(counts > 0){
                Monitor.Wait(lockobj);
            }
        }
    }

    public void CountDown(){
        lock(lockobj){
            counts--;
            Monitor.PulseAll(lockobj);
        }
    }
}

有了這個(gè)東西,上面的代碼可以改的更少一些。


CountDownLatch cdl = new CountDownLatch(N);
for(int i = 0; i < N; i++){
     ThreadPool.QueueUserWorkItem(new WaitCallback(Tasks[i]), cdl);
}
cdl.Awati();

而對(duì)于任務(wù)的代碼來說,在結(jié)尾處吧對(duì)WaitHandle的Set方法的調(diào)用改為對(duì)CountDownLatch類的CountDown方法的調(diào)用即可。
最后,我想說的是其實(shí)沒必要把思路都拘束在.Net上或者Java上,相互借鑒會(huì)讓思路更開闊一些。不過有句心里話想說的就是,其實(shí)Java的類庫(kù)在某些方面做的比.Net好一些。

【編輯推薦】

  1. 部署和分發(fā).NET應(yīng)用程序的兩種方法
  2. 詳解.NET編程過程中的線程沖突
  3. 作為ASP.NET開發(fā)人員必須養(yǎng)成的編程習(xí)慣

本文名稱:分析.NET中的CountDownLatch類
分享URL:http://m.5511xx.com/article/dpjjpie.html