一個簡易的、輕量級的方法並行執行線程輔助類

　　在實際應用中，經常要讓多個方法並行執行以節約運行時間，線程就是必不可少的了，而多線程的管理經常又是一件頭疼的事情，比如方法並行執行異步的返回問題，方法並行執行的超時問題等等，因此這里分享一個簡易的、輕量級的方法並行執行線程輔助類。

　　線程管理輔助類的兩個目標：

　　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, 0);
        }

        /// <summary>
        /// 等待所有線程執行完畢
        /// </summary>
        /// <param name="overMiniseconds">超時時間（毫秒）</param>
        public void WaitAll(int overMiniseconds = 0)
        {
            int checkCount = 0;

            // 自旋
            while (Interlocked.CompareExchange(ref this.currThreadCount, 0, this.totalThreadCount) != this.totalThreadCount)
            {
                // 超過超時時間返回
                if (overMiniseconds > 0)
                {
                    if (checkCount >= overMiniseconds)
                    {
                        break;
                    }
                }

                checkCount++;

                Thread.Sleep(1);
            }
        }

        /// <summary>
        /// 設置信號量，表示單線程執行完畢
        /// </summary>
        public void SetOne()
        {
            Interlocked.Increment(ref this.currThreadCount);
        }
    }
}

　　使用示例：

    public class ThreadHelperTest
    {
        /// <summary>
        /// 線程幫助類
        /// </summary>
        private ThreadHelper threadHelper;

        public void Test()
        {
            // 開啟方法方法並行執行
            int funcCount = 5;

            this.threadHelper = new ThreadHelper(funcCount);

            for (int i = 0; i < funcCount; i++)
            {
                Action<int> action = new Action<int>(TestFunc);
                action.BeginInvoke(i, null, null);
            }

            // 等待方法執行，超時時間12ms，12ms后強制結束
            threadHelper.WaitAll(12);

            Console.WriteLine("所有方法執行完畢！");
        }

        private void TestFunc(int i)
        {
            try
            {
                Console.WriteLine("方法{0}執行！");
                Thread.Sleep(10);
            }
            finally
            {
                // 方法執行結束
                this.threadHelper.SetOne();
            }
        }
    }

　　總結：

　　1、該線程幫助類只是一個簡易的線程管理類，還缺少很多功能，比如異常處理等，不過一般的情況下還是比較使用的。