多線程學習之限制同時運行的線程數量

最近閑暇之余，來搞搞，多線程學習，只為下個項目做准備，隨着項目優化，開發，性能的考慮，慢慢要用到些以前不用的東西，先開始熟悉熟悉

先把東西放上來，歡迎大家賜教，比較好久木玩這東西了，肯定不完善，希望大家提出寶貴意見啊(嘿嘿~~)

 

大概功能描述：為了提高數據處理速度，把任務隊列分別交給不同子線程去完成，同時對啟動的新線程數量限制，避免線程數量過多照成機器卡殼

 

using System;
using System.Threading;
namespace ThreadTest
{
  class ThreadMaxNum
    {
        static int NowThCount = 0;//當前已啟動線程數量
        static int MaxThCount = 5;//允許最大啟動線程數量
        static int RunNum = 15;//當前有多少個要處理的程序[任務隊列]
        public static void Run()
        {
            Thread NewTh;
            while (true)
            {
                //當前沒有活動線程，且 任務隊列 為空 說明任務完成了
                if (NowThCount == 0 && RunNum == 0)
                    break;
                
                //任務隊列為空 ，但是又線程運行中，就讓主線程休息 下，在判斷
                if (RunNum == 0 && NowThCount != 0) 
                {
                    Thread.Sleep(2000);//休息
                    continue;//再次判斷
                }

                //如果 當前活動線程數量 達到最大線程 就不在 開始新的任務
                if (NowThCount >= MaxThCount)
                {
                    Thread.Sleep(2000);//休息
                    continue;//再次判斷
                }

                //有 隊列>0，且沒有達到最大
                if (RunNum > 0 && NowThCount < MaxThCount)
                {
                    //一個任務已經去執行了，應該減掉個,執行結果如何，這里不判斷
                    RunNum--;

                    NewTh = new Thread(new ThreadStart(RunNewFun));
                    NewTh.Start();
                }
            }
            Console.WriteLine("任務隊列，執行完成："+RunNum);
        }
        static void RunNewFun()
        {
            NowThCount++;//加個

            Console.WriteLine("我是線程：" + Thread.CurrentThread.ManagedThreadId);
            Thread.Sleep(3000);
            Console.WriteLine("我是線程：" + Thread.CurrentThread.ManagedThreadId + ".....結束");

            NowThCount--;//減去
        }
    }
}

 

 

寫在最后：感覺程序還不打完善，運行中會不會因為特殊原因照成異常，還在測試中…..