等待线程池内线程执行完成的一种方法
通过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));
}
}


