等待线程池内线程执行完成的一种方法

作者:互联网   出处:控件中国网   2014-11-05 19:22:01   阅读:1

等待线程池内线程执行完成的一种方法

通过AutoResetEvent实现等待线程池内线程执行完成,并进行计时计算。

由于方法比较简单直接贴出代码,如下:

/// <summary>
 /// 等待线程池内的所有线程执行完成的一种方法
 /// </summary>
     public class ExecutedThreadPool
     {
         public void ThreadPoolFinish()
         {
 
             int iterations = 10;//迭代的次数
             int doneCount = iterations;//用于AutoResetEvent返回信号量
             int display = 0;//方便观察结果的数据显示
             AutoResetEvent done = new AutoResetEvent(false);
             DateTime startDt = DateTime.Now;//用作时间开始的计时,和最终执行完成多线程的时间比较。目的:验证watcher的时间
             Stopwatch watcher = Stopwatch.StartNew();
             for (int i = 0; i < iterations; i++)
             {
                 ThreadPool.QueueUserWorkItem(r =>
                 {
                     Thread.Sleep(1000);//方便观察时间差
                     Console.WriteLine(string.Format("DateTime:{0},Number:{1}", DateTime.Now, Interlocked.Increment(ref display)));
                     if (Interlocked.Decrement(ref doneCount) == 0)
                     {
                         done.Set();//发出信号量
                     }
 
                 });
             }
             done.WaitOne();//阻止当前线程,直到接收到信号量
             Console.WriteLine(string.Format("Elapsed:{0},Start Time:{1}", watcher.Elapsed, startDt));
         }
     }

 

Copyright© 2006-2015 ComponentCN.com all rights reserved.重庆磐岩科技有限公司(控件中国网) 版权所有 渝ICP备12000264号 法律顾问:元炳律师事务所
客服软件
live chat