C# ThreadPool/線程池(執行序池)

資料來源: https://py3939.pixnet.net/blog/post/28264441

https://dotblogs.com.tw/atowngit/2009/12/20/12557

範例01.

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading;

namespace ThreadPoo
{
    class ThreadPool1
    {
        static void Main(string[] args)
        {
            System.Threading.WaitCallback waitCallback = new WaitCallback(MyThreadWork);
            ThreadPool.QueueUserWorkItem(waitCallback, "First");
            ThreadPool.QueueUserWorkItem(waitCallback, "Second");
            ThreadPool.QueueUserWorkItem(waitCallback, "Third");
            Console.WriteLine("Main thread exits.");
            Console.ReadKey();//等待並結束
        }

        static void MyThreadWork(object state)
        {
            Console.WriteLine("Begin of {0}", (string)state);
            Thread.Sleep(5000);
            Console.WriteLine("End of {0}", (string)state);
        }
    }
}

輸出結果 :

Main thread exits.
Begin of First
Begin of Third
Begin of Second
End of First
End of Third
End of Second

範例02(匿名委派).

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading;

namespace ThreadPoo
{
    class ThreadPool1
    {
        static void Main(string[] args)
        {
            ThreadPool.QueueUserWorkItem(delegate
            {
                Console.WriteLine("Begin of {0}", "First");
                Thread.Sleep(5000);
                Console.WriteLine("End of {0}", "First");
            });
            Console.WriteLine("Main thread exits.");
            Console.ReadKey();
        }
    }
}

範例03.

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading;

namespace ThreadPoo
{
    public class TaskInfo
    {
        public string Who;
        public TaskInfo(string Value)
        {
            Who = Value;
        }
    }

    class ThreadPool2
    {
        static void Main(string[] args)
        {
            TaskInfo ti = new TaskInfo("Jack");
            ThreadPool.QueueUserWorkItem(new WaitCallback(MyThreadWork), ti);
            Thread.Sleep(1000);
            Console.WriteLine("Main thread exits.");
            Console.ReadKey();
        }

        static void MyThreadWork(object state)
        {
            TaskInfo ti = (TaskInfo)state;
            Console.WriteLine("Begin of {0}", ti.Who);
            Thread.Sleep(5000);
            Console.WriteLine("End of {0}", ti.Who);
        }
    }
}

輸出結果 :

Begin of Jack
Main thread exits.
End of Jack

範例04.

using System.Threading;

namespace TestThreadPool {
    class Program {
        static void Main(string[] args) {
            Console.WriteLine("以下開始將工作排入執行緒管理工作佇列 !!");
            Console.WriteLine("***********************************************");

            for (int n1 = 0; n1 < 3; n1++) {
                //建立 WaitCallback 物件，並且指定回呼方法
                WaitCallback myWaitCallback = new WaitCallback(WorkA);
                //將 WaitCallback 排入排程
                ThreadPool.QueueUserWorkItem(myWaitCallback, n1 + 1);
                //使畫面慢慢輸出
                Thread.Sleep(1000);
            }

            Console.WriteLine("*********************************************");

            for (int n1 = 0; n1 < 3; n1++) {
                ThreadPool.QueueUserWorkItem(new WaitCallback(WorkB), n1 + 1);
                Thread.Sleep(1000);
            }

            Console.WriteLine("***********************************");

            for (int n1 = 0; n1 < 3; n1++) {
                ThreadPool.QueueUserWorkItem(new WaitCallback(WorkC), n1 + 1);
                Thread.Sleep(1000);
            }
            Console.ReadLine();
        }

        public static void WorkA(object o) {
            string Name;
            //取得執行緒的雜湊碼
            Name = "使用的執行緒編號 Thread ID# = " + Thread.CurrentThread.GetHashCode();
            Console.WriteLine
              ("這是第一組被排入佇列的第 {0} 個工作，{1}", o, Name);
            Console.WriteLine("此工作執行緒結束 !! ");

        }

        public static void WorkB(object o) {
            string Name;
            Name = "使用的執行緒編號 Thread ID# = " +
              Thread.CurrentThread.GetHashCode();
            Console.WriteLine
              ("這是第二組被排入佇列的第 {0} 個工作，{1}", o, Name);
            Console.WriteLine("此工作執行緒暫停 2 秒 !! ");
            Thread.Sleep(2000);
        }

        public static void WorkC(object o) {
            string Name;
            Name = "使用的執行緒編號 Thread ID# = " +
              Thread.CurrentThread.GetHashCode();
            Console.WriteLine
              ("這是第三組被排入佇列的第 {0} 個工作，{1}", o, Name);
            Console.WriteLine("此工作執行緒暫停 10 秒 !! ");
            Thread.Sleep(10000);
        }
    }
}