一个简易的、轻量级的方法并行执行线程辅助类 在实际应用中，经常要让多个方法并行执行以节约运行时间，线程就是必不可少的了，而多线程的管理经常又是一件头疼的事情，比如方法并行执行异步的返回问题，方法并行执行的超时问题等等，因此这里分享一个简易的、轻量级的方法并行执行线程辅助类。
线程管理辅助类的两个目标：
1、多个线程方法并行执行，主线程等待，需要知道所有子线程执行完毕；
2、异步执行方法需要设置超时时间，超时可以跳过该方法，主线程直接返回；
3、轻量级，虽然微软提供了线程等待、超时等可用组件，如ManualResetEvent，但那是内核对象，占用系统资源较多。
设计实现：
1、该类内部维护两个变量，异步执行方法总线程数totalThreadCount，当前执行完毕线程数据currThreadCount；
2、两个开放方法，WaitAll等待执行，SetOne设置方法执行结束，每一个方法执行完毕调用SetOne，currThreadCount数量加1，同时WaitAll判断currThreadCount与totalThreadCount是否相等，相等即表示所有方法执行完毕，返回；
3、为了实现线程安全，currThreadCount的变量处理使用Interlocked。
代码实现：
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading; namespace Loncin.CodeGroup10.Utility
{
public class ThreadHelper
{
/// <summary>
/// 总线程数
/// </summary>
private int totalThreadCount; /// <summary>
/// 当前执行完毕线程数
/// </summary>
private int currThreadCount; /// <summary>
/// 构造函数
/// </summary>
/// <param name="totalThreadCount">总线程数</param>
public ThreadHelper(int totalThreadCount)
{
Interlocked.Exchange(ref this.totalThreadCount, totalThreadCount);
Interlocked.Exchange(ref this.currThreadCount, );
} /// <summary>
/// 等待所有线程执行完毕
/// </summary>
/// <param name="overMiniseconds">超时时间（毫秒）</param>
public void WaitAll(int overMiniseconds = )
{
int checkCount = ; // 自旋
while (Interlocked.CompareExchange(ref this.currThreadCount, , this.totalThreadCount) != this.totalThreadCount)
{
// 超过超时时间返回
if (overMiniseconds > )
{
if (checkCount >= overMiniseconds)
{
break;
}
} checkCount++; Thread.Sleep();
}
} /// <summary>
/// 设置信号量，表示单线程执行完毕
/// </summary>
public void SetOne()
{
Interlocked.Increment(ref this.currThreadCount);
}
}
}
public class ThreadHelperTest
{
/// <summary>
/// 线程帮助类
/// </summary>
private ThreadHelper threadHelper; public void Test()
{
// 开启方法方法并行执行
int funcCount = ; this.threadHelper = new ThreadHelper(funcCount); for (int i = ; i < funcCount; i++)
{
Action<int> action = new Action<int>(TestFunc);
action.BeginInvoke(i, null, null);
} // 等待方法执行，超时时间12ms，12ms后强制结束
threadHelper.WaitAll(); Console.WriteLine("所有方法执行完毕！");
} private void TestFunc(int i)
{
try
{
Console.WriteLine("方法{0}执行！");
Thread.Sleep();
}
finally
{
// 方法执行结束
this.threadHelper.SetOne();
}
}
}