成人免费xxxxx在线视频软件_久久精品久久久_亚洲国产精品久久久_天天色天天色_亚洲人成一区_欧美一级欧美三级在线观看

分析.NET中的CountDownLatch類

開發(fā) 后端
本文將分析.NET中的CountDownLatch類,透過作者在實際工作中碰到的有N個互不相關(guān)的任務要在線程池中跑,但有一個線程要等待N個任務完成之后才能繼續(xù)的問題,為大家簡單介紹下。

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

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

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);
}

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

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);
        }
    }
}

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


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

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

【編輯推薦】

  1. 部署和分發(fā).NET應用程序的兩種方法
  2. 詳解.NET編程過程中的線程沖突
  3. 作為ASP.NET開發(fā)人員必須養(yǎng)成的編程習慣
責任編輯:彭凡 來源: cnblogs
相關(guān)推薦

2021-09-08 06:51:53

CountDownLa閉鎖源碼

2009-10-15 10:57:16

VB.NET Text

2016-08-31 16:07:54

Python實例

2009-08-04 17:42:23

DataSourceCASP.NET

2009-02-27 08:56:30

IIS.Net原理分析

2009-09-02 18:28:55

.NET框架ESBasic

2009-08-05 18:42:05

xsd.exe

2022-03-29 07:20:04

密封類.NET性能

2024-04-07 09:04:18

Parallel 類編程工具.NET

2009-07-22 18:08:00

ASP.NET基類

2009-12-18 17:25:21

ADO.NET類庫

2009-10-23 10:58:33

VB.NET條件語句

2009-10-12 09:02:03

SmartRWLock

2009-11-04 14:54:51

.NET類

2009-10-30 10:58:45

VB.NET創(chuàng)建類

2011-06-21 09:22:53

Random類

2009-08-25 14:03:17

2010-06-18 09:23:33

SortedSet.NET 4

2015-08-21 10:36:32

.NETRedis

2019-07-02 15:21:39

緩存NET單線程
點贊
收藏

51CTO技術(shù)棧公眾號

主站蜘蛛池模板: 亚洲精品一二三区 | 久久久精品| 国产一区二区不卡 | 亚洲成人观看 | 日本久久网站 | 超碰日本 | 99pao成人国产永久免费视频 | 欧美老少妇一级特黄一片 | 欧美激情国产精品 | 亚洲黄色国产 | 欧洲精品在线观看 | 亚洲国产成人在线观看 | 成年视频在线观看 | 日韩欧美不卡 | 久久51| www.久草.com| 精品无码久久久久国产 | 婷婷久久久久 | 91视频进入 | 欧美理伦片在线播放 | 国产欧美日韩在线观看 | 欧美精品导航 | 中文字幕亚洲欧美日韩在线不卡 | 色婷婷综合久久久中字幕精品久久 | 99视频在线免费观看 | a级大片免费观看 | 欧美精品一区二区三区在线 | 欧美极品在线观看 | 综合网在线 | 国产精品视频不卡 | 久热爱| 日韩在线观看一区 | 狠狠干美女 | 国产成人精品一区二区三 | 粉嫩在线| 亚洲九色 | 91社影院在线观看 | 欧美v日韩 | 91小视频在线 | 久久亚洲春色中文字幕久久久 | 男女久久久|