需求：成員A可能有幾十個，我需要更新所有的A，然後根據A的資料，去更新成員B。

解決方案:思路是想通過多執行緒更新所有的A，然後通過等待執行緒來確定所有的A是否都更新完，最後更新B。

Member B = ....;//B成員的model
IList<Member> list = ......;//查出所有的A成員，裝進list裡。

ManualResetEvent[] manualEvents = new ManualResetEvent[list.Count];
//更新所有的A成員
for (int i = 0; i < list.Count; i++)
{
    manualEvents[i] 
 
= new ManualResetEvent(false);//初始化的ManualResetEvent必須是false
    model = new te();//目前我只知道此處只能傳一個引數，所以為了傳遞多個引數，我寫了個model，然後把要引數都放進model裡
    model.MRevent = manualEvents[i];
    model.member = list[i];//此處是我處理資料需要的引數,把成員的model傳進去
    ThreadPool.QueueUserWorkItem(new WaitCallback(UpdateMember), model);
}
 
//等待所有執行緒執行完畢
WaitHandle.WaitAll(manualEvents);

//更新B成員
model = new te();
model.member = B;
model.MRevent = new ManualResetEvent(false);
UpdateMember(model);

處理資料的方法

public void UpdateMember(object tsmodel)
{
    te stateInfo = (te)tsmodel;
    Member member = stateInfo.member;//中間為處理資料更新成員資料
 

    ......

    stateInfo.MRevent.Set(); //將事件狀態設定為終止狀態,允許一個或多個等待執行緒繼續（我個人理解是呼叫此方法,及為該執行緒結束,ManualResetEvent應該變成true）
}

新建立的model

public class te
{
    public Member member{ get; set; }
    public ManualResetEvent MRevent { get; set; }//小於64執行緒的時候使用
    public MutipleThreadResetEvent MTRevent { get; set; }//大於64執行緒的時候使用
}

此處出現了新問題:

當執行緒大於64條時，會報錯。應該是WaitHandle.WaitAll(manualEvents);這等待的執行緒數不能大於64。

錯誤資訊：waithandles 的數目必須少於或等於 64 個。

原理：封裝一個ManualResetEvent物件，一個計數器current，提供SetOne和WaitAll方法；

主執行緒呼叫WaitAll方法使ManualResetEvent物件等待喚醒訊號；

各個子執行緒呼叫setOne方法 ，setOne每執行一次current減1，直到current等於0時表示所有子執行緒執行完畢 ,呼叫ManualResetEvent的set方法，這時主執行緒可以執行WaitAll之後的步驟。

目標：減少ManualResetEvent物件的大量產生和使用的簡單性。

/********************************************************************************
 * Copyright © 2001 - 2010Comit. All Rights Reserved.
 * 檔案：MutipleThreadResetEvent.cs
 * 作者：楊柳
 * 日期：2010年11月13日
 * 描述：封裝 ManualResetEvent ，該類允許一次等待N（N>64）個事件執行完畢
 * 
 *       解決問題：WaitHandle.WaitAll(evetlist)方法最大隻能等待64個ManualResetEvent事件
 * *********************************************************************************/
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading;
 
namespace TestMutipleThreadRestEvent
{
    /// <summary>
    ///  封裝ManualResetEvent
    /// </summary>
    public class MutipleThreadResetEvent : IDisposable
    {
        private readonly ManualResetEvent done;
        private readonly int total;
        private long current;
 
        /// <summary>
        /// 建構函式
        /// </summary>
        /// <param name="total">需要等待執行的執行緒總數</param>
        public MutipleThreadResetEvent(int total)
        {
            this.total = total;
            current = total;
            done = new ManualResetEvent(false);
        }
 
        /// <summary>
        /// 喚醒一個等待的執行緒
        /// </summary>
        public void SetOne()
        {
            // Interlocked 原子操作類 ,此處將計數器減1
            if (Interlocked.Decrement(ref current) == 0)
            {
                //當所以等待執行緒執行完畢時，喚醒等待的執行緒
                done.Set();
            }
        }
 
        /// <summary>
        /// 等待所以執行緒執行完畢
        /// </summary>
        public void WaitAll()
        {
            done.WaitOne();
        }
 
        /// <summary>
        /// 釋放物件佔用的空間
        /// </summary>
        public void Dispose()
        {
            ((IDisposable)done).Dispose();
        }
    } 
 
}

本質就是隻通過1個ManualResetEvent 物件就可以實現同步N（N可以大於64）個執行緒

修改後的方法：(黃色熒光筆的都是改動的程式碼)

Member B = ....;//B成員的model
IList<Member> list = ......;//查出所有的A成員，裝進list裡。
//更所有A成員
using (var countdown = new MutipleThreadResetEvent(list.Count))
{
    for (int i = 0; i < list.Count; i++)
    {
        model = new te();
        model.MTRevent = countdown;
        model.member = list[i];
        //開啟N個執行緒，傳遞MutipleThreadResetEvent物件給子執行緒
        ThreadPool.QueueUserWorkItem(new WaitCallback(UpdateMember), model);
    }

    //等待所有執行緒執行完畢
    countdown.WaitAll();
}
//更新B成員
using (var countdown = new MutipleThreadResetEvent(1))
{
    model = new te();
    model.MTRevent = countdown;
    model.member = B;
    //開啟N個執行緒，傳遞MutipleThreadResetEvent物件給子執行緒
    ThreadPool.QueueUserWorkItem(new WaitCallback(UpdateMember), model);
    //等待所有執行緒執行完畢
    countdown.WaitAll();
}

處理資料的方法需要小改一下：

public void UpdateMember(object tsmodel)
{
    te stateInfo = (te)tsmodel;
    Member member = stateInfo.member;
    //中間為處理資料更新成員資料
    ......

    stateInfo.MTRevent.SetOne();//此處呼叫封裝的方法
}

此時，大於64條執行緒的可以使用了。