亚洲乱码中文字幕综合,中国熟女仑乱hd,亚洲精品乱拍国产一区二区三区,一本大道卡一卡二卡三乱码全集资源,又粗又黄又硬又爽的免费视频

C#多線程等待所有子線程結(jié)束的示例

 更新時(shí)間:2020年12月04日 09:58:24   作者:Bruce-  
這篇文章主要介紹了C#多線程等待所有子線程結(jié)束的示例,幫助大家更好的理解和學(xué)習(xí)c#編程語(yǔ)言,感興趣的朋友可以了解下

在使用多線程過(guò)程中,可能會(huì)遇到在一些情況下必須等待子線程全部執(zhí)行結(jié)束后主線程才進(jìn)行下一步,

做法如下:

 //在使用多線程過(guò)程中,可能會(huì)遇到在一些情況下必須等待子線程全部執(zhí)行結(jié)束后主線程才進(jìn)行下一步,做法如下
      List<ManualResetEvent> manualEvents = new List<ManualResetEvent>();//創(chuàng)建線程等待集合
      for (int i = 0; i < 64; i++) //WaitHandles 的數(shù)目必須少于或等于 64 個(gè),所以最大線程數(shù)為64
      {
        MB m = new MB();//自定義類,用于傳參
        m.mre= new ManualResetEvent(false);
        m.ID = i;

        manualEvents.Add(m.mre);
        ThreadPool.QueueUserWorkItem(ThreadMethod, m);
      }
      WaitHandle.WaitAll(manualEvents.ToArray());//等待所有線程結(jié)束
      Console.WriteLine("Thread Finished!");
private static void ThreadMethod(object obj)
    {
      MB m = (MB)obj;
      Thread.Sleep(1000);//等待1秒,用于模擬系統(tǒng)在處理事情
      m.mre.Set();//將事件設(shè)置為終止?fàn)顟B(tài)
      Console.WriteLine("Thread execute:" + m.ID);
    }

以上方法在處理時(shí)當(dāng)線程數(shù)超過(guò)64時(shí)報(bào)錯(cuò) WaitHandles 的數(shù)目必須少于或等于 64 個(gè),所以最大線程數(shù)為64
解決方法如下:

        using (var countdown = new MutipleThreadResetEvent(list.Count))
        {
          for (int i = 0; i < list.Count; i++)
          {
            //開啟N個(gè)線程,傳遞MutipleThreadResetEvent對(duì)象給子線程
            Param p = new Param();
            p.countdown = countdown;
            p.Path = pa[i];
            ThreadPool.QueueUserWorkItem(MyHttpRequest, p);
          }

          //等待所有線程執(zhí)行完畢
          countdown.WaitAll();
        }
public class MutipleThreadResetEvent: IDisposable
  {
    private readonly ManualResetEvent done;
    private readonly int total;
    private long current;

    /// <summary>
    /// 構(gòu)造函數(shù)
    /// </summary>
    /// <param name="total">需要等待執(zhí)行的線程總數(shù)</param>
    public MutipleThreadResetEvent(int total)
    {
      this.total = total;
      current = total;
      done = new ManualResetEvent(false);
    }

    /// <summary>
    /// 喚醒一個(gè)等待的線程
    /// </summary>
    public void SetOne()
    {
      // Interlocked 原子操作類 ,此處將計(jì)數(shù)器減1
      if (Interlocked.Decrement(ref current) == 0)
      {
        //當(dāng)所以等待線程執(zhí)行完畢時(shí),喚醒等待的線程
        done.Set();
      }
    }

    /// <summary>
    /// 等待所以線程執(zhí)行完畢
    /// </summary>
    public void WaitAll()
    {
      done.WaitOne();
    }

    /// <summary>
    /// 釋放對(duì)象占用的空間
    /// </summary>
    public void Dispose()
    {
      ((IDisposable)done).Dispose();
    }
  }

以上就是C#多線程等待所有子線程結(jié)束的示例的詳細(xì)內(nèi)容,更多關(guān)于c# 多線程等待子線程結(jié)束的資料請(qǐng)關(guān)注腳本之家其它相關(guān)文章!

相關(guān)文章

最新評(píng)論