網站首頁編程語言正文

C#多線程之線程池ThreadPool用法_C#教程

作者：.NET開發菜鳥 ? 更新時間： 2022-05-09 編程語言

一、ThreadPool

ThreadPool是.Net Framework 2.0版本中出現的。

ThreadPool出現的背景：Thread功能繁多，而且對線程數量沒有管控，對于線程的開辟和銷毀要消耗大量的資源。每次new一個THread都要重新開辟內存。

如果某個線程的創建和銷毀的代價比較高，同時這個對象還可以反復使用的，就需要一個池子（容器），保存多個這樣的對象，需要用的時候從池子里面獲取，用完之后不用銷毀，在放到池子里面。這樣不但能節省內存資源，提高性能，而且還能管控線程的總數量，防止濫用。這時就需要使用ThreadPool了。

我們來看看ThreadPool中常用的一些方法。

1、QueueUserWorkItem()

QueueUserWorkItem()方法用來啟動一個多線程。我們先看看方法的定義：

QueueUserWorkItem()方法有一個WaitCallback類型的參數，在看看WaitCallback的定義：

可以看到WaitCallback就是有一個object類型參數的委托，所以ThreadPool啟動多線程使用下面的代碼：

using System;
using System.Threading;

namespace ThreadPoolDemo
{
    class Program
    {
        static void Main(string[] args)
        {
            Console.WriteLine($"start ThreadId: {Thread.CurrentThread.ManagedThreadId.ToString("00")}");
            // ThreadPoll啟動多線程
            ThreadPool.QueueUserWorkItem(p => DoSomethingLong("啟動多線程"));

            Console.WriteLine($"end ThreadId: {Thread.CurrentThread.ManagedThreadId.ToString("00")}");
            Console.ReadKey();
        }

        static void DoSomethingLong(string para)
        {
            Console.WriteLine($"{para}  ThreadId: {Thread.CurrentThread.ManagedThreadId.ToString("00")}");
        }
    }
}

運行結果：

2、GetMaxThreads()

GetMaxThreads()用來獲取線程池中最多可以有多少個輔助線程和最多有多少個異步線程。

ThreadPool.GetMaxThreads(out int workerThreads, out int completionPortThreads);
Console.WriteLine($"GetMaxThreads workerThreads={workerThreads} completionPortThreads={completionPortThreads}");

程序運行結果：

3、GetMinThreads()

GetMinThreads()用來獲取線程池中最少可以有多少個輔助線程和最少有多少個異步線程。

ThreadPool.GetMinThreads(out int minworkerThreads, out int mincompletionPortThreads);
Console.WriteLine($"GetMinThreads workerThreads={minworkerThreads} completionPortThreads={mincompletionPortThreads}");

程序運行結果：

4、SetMaxThreads()和SetMinThreads()

SetMaxThreads()和SetMinThreads()分別用來設置線程池中最多線程數和最少線程數。

using System;
using System.Threading;

namespace ThreadPoolDemo
{
    class Program
    {
        static void Main(string[] args)
        {
            Console.WriteLine($"start ThreadId: {Thread.CurrentThread.ManagedThreadId.ToString("00")}");
            // ThreadPoll啟動多線程
            ThreadPool.QueueUserWorkItem(p => DoSomethingLong("啟動多線程"));

            // 獲取最大線程
            ThreadPool.GetMaxThreads(out int workerThreads, out int completionPortThreads);
            Console.WriteLine($"GetMaxThreads workerThreads={workerThreads} completionPortThreads={completionPortThreads}");

            // 獲取最小線程
            ThreadPool.GetMinThreads(out int minworkerThreads, out int mincompletionPortThreads);
            Console.WriteLine($"GetMinThreads workerThreads={minworkerThreads} completionPortThreads={mincompletionPortThreads}");

            // 設置線程池線程
            SetThreadPool();
            // 輸出設置后的線程池線程個數
            Console.WriteLine("輸出修改后的最多線程數和最少線程數");
            ThreadPool.GetMaxThreads(out int maxworkerThreads, out int maxcompletionPortThreads);
            Console.WriteLine($"GetMaxThreads workerThreads={maxworkerThreads} completionPortThreads={maxcompletionPortThreads}");
            ThreadPool.GetMinThreads(out int workerEditThreads, out int completionPortEditThreads);
            Console.WriteLine($"GetMinThreads workerThreads={workerEditThreads} completionPortThreads={completionPortEditThreads}");
            Console.WriteLine($"end ThreadId: {Thread.CurrentThread.ManagedThreadId.ToString("00")}");
            Console.ReadKey();
        }

        static void DoSomethingLong(string para)
        {
            Console.WriteLine($"{para}  ThreadId: {Thread.CurrentThread.ManagedThreadId.ToString("00")}");
        }

        /// 
        /// 設置線程池線程個數
        /// 
        static void SetThreadPool()
        {

            Console.WriteLine("************設置最多線程數和最少線程數****************");
            // 設置最大線程
            ThreadPool.SetMaxThreads(16, 16);
            // 設置最小線程
            ThreadPool.SetMinThreads(8, 8);

        }
    }
}

程序運行結果：

二、線程等待

先來看下面一個小例子：

ThreadPool.QueueUserWorkItem(p => DoSomethingLong("啟動多線程"));
Console.WriteLine("等著QueueUserWorkItem完成后才執行");

我們想讓異步多線程執行完以后再輸出“等著QueueUserWorkItem完成后才執行” 這句話，上面的代碼運行效果如下：

從截圖中可以看出，效果并不是我們想要的，Thread中提供了暫停、恢復等API，但是ThreadPool中沒有這些API，在ThreadPool中要實現線程等待，需要使用到ManualResetEvent類。

ManualResetEvent類的定義如下：

ManualResetEvent需要一個bool類型的參數來表示暫停和停止。上面的代碼修改如下：

// 參數設置為false
ManualResetEvent manualResetEvent = new ManualResetEvent(false);
ThreadPool.QueueUserWorkItem(p => 
{
      DoSomethingLong("啟動多線程");
      // 設置為true
      manualResetEvent.Set();
});
// 
manualResetEvent.WaitOne();
Console.WriteLine("等著QueueUserWorkItem完成后才執行");

結果：

ManualResetEvent類的參數值執行順序如下：

(1)、false--WaitOne等待--Set--true--WaitOne直接過去
(2)、true--WaitOne直接過去--ReSet--false--WaitOne等待

注意：一般情況下，不要阻塞線程池中的線程，因為這樣會導致一些無法預見的錯誤。來看下面的一個例子：

static void SetWait()
{
            // 設置最大線程
            ThreadPool.SetMaxThreads(16, 16);
            // 設置最小線程
            ThreadPool.SetMinThreads(8, 8);
            ManualResetEvent manualResetEvent = new ManualResetEvent(false);
            for (int i = 0; i < 20; i++)
            {
                int k = i;
                ThreadPool.QueueUserWorkItem(p =>
                {
                    Console.WriteLine(k);
                    if (k < 18)
                    {
                        manualResetEvent.WaitOne();
                    }
                    else
                    {
                        // 設為true
                        manualResetEvent.Set();
                    }
                });
            }
            if (manualResetEvent.WaitOne())
            {
                Console.WriteLine("沒有死鎖、、、");
            }
            else
            {
                Console.WriteLine("發生死鎖、、、");
            }
}

啟動20個線程，如果k小于18就阻塞當前的線程，結果：

從截圖中看出，只執行了16個線程，后面的線程沒有執行，這是為什么呢？因為我們在上面設置了線程池中最多可以有16個線程，當16個線程都阻塞的時候，會造成死鎖，所以后面的線程不會再執行了。

三、線程重用

ThreadPool可以很好的實現線程的重用，這樣就可以減少內存的消耗，看下面的代碼：

/// 
/// 測試ThreadPool線程重用
/// 
static void ThreadPoolTest()
{
            // 線程重用
            ThreadPool.QueueUserWorkItem(t =>DoSomethingLong("ThreadPool"));
            ThreadPool.QueueUserWorkItem(t =>DoSomethingLong("ThreadPool"));
            ThreadPool.QueueUserWorkItem(t =>DoSomethingLong("ThreadPool"));
            ThreadPool.QueueUserWorkItem(t =>DoSomethingLong("ThreadPool"));
            ThreadPool.QueueUserWorkItem(t =>DoSomethingLong("ThreadPool"));
            Thread.Sleep(10 * 1000);
            Console.WriteLine("前面的計算都完成了。。。。。。。。");
            ThreadPool.QueueUserWorkItem(t =>DoSomethingLong("ThreadPool"));
            ThreadPool.QueueUserWorkItem(t =>DoSomethingLong("ThreadPool"));
            ThreadPool.QueueUserWorkItem(t =>DoSomethingLong("ThreadPool"));
            ThreadPool.QueueUserWorkItem(t =>DoSomethingLong("ThreadPool"));
            ThreadPool.QueueUserWorkItem(t =>DoSomethingLong("ThreadPool"));
}

然后在Main方法里面調用該方法，輸出結果如下圖所示：

我們在代碼里面總共創建了10個線程，而結果里面只有4個線程ID，這就說明ThreadPool可以實現線程的重用。下面我們在看看Thread是否可以實現線程的重用，代碼如下：

/// 
/// 測試Thread線程重用
/// 
static void ThreadTest()
{
            for (int i = 0; i < 5; i++)
            {
                new Thread(() => DoSomethingLong("Threads")).Start();
            }
            Thread.Sleep(10 * 1000);
            Console.WriteLine("前面的計算都完成了。。。。。。。。");
            for (int i = 0; i < 5; i++)
            {
                new Thread(() => DoSomethingLong("btnThreads")).Start();
            }
}

然后在Main方法里面調用，輸入結果如下圖所示：

我們同樣在代碼里面創建了10個線程，結果輸出了10個線程的ID，這就說明Thread不能實現線程的重用。同樣也說明THread的效率沒有ThreadPool高。

程序完整代碼：

using System;
using System.Threading;

namespace ThreadPoolDemo
{
    class Program
    {
        static void Main(string[] args)
        {
            Console.WriteLine($"start ThreadId: {Thread.CurrentThread.ManagedThreadId.ToString("00")}");
            //// ThreadPoll啟動多線程
            //ThreadPool.QueueUserWorkItem(p => DoSomethingLong("啟動多線程"));

            //// 獲取最大線程
            //ThreadPool.GetMaxThreads(out int workerThreads, out int completionPortThreads);
            //Console.WriteLine($"GetMaxThreads workerThreads={workerThreads} completionPortThreads={completionPortThreads}");

            //// 獲取最小線程
            //ThreadPool.GetMinThreads(out int minworkerThreads, out int mincompletionPortThreads);
            //Console.WriteLine($"GetMinThreads workerThreads={minworkerThreads} completionPortThreads={mincompletionPortThreads}");

            //// 設置線程池線程
            //SetThreadPool();
            //// 輸出設置后的線程池線程個數
            //Console.WriteLine("輸出修改后的最多線程數和最少線程數");
            //ThreadPool.GetMaxThreads(out int maxworkerThreads, out int maxcompletionPortThreads);
            //Console.WriteLine($"GetMaxThreads workerThreads={maxworkerThreads} completionPortThreads={maxcompletionPortThreads}");
            //ThreadPool.GetMinThreads(out int workerEditThreads, out int completionPortEditThreads);
            //Console.WriteLine($"GetMinThreads workerThreads={workerEditThreads} completionPortThreads={completionPortEditThreads}");
            //Console.WriteLine($"end ThreadId: {Thread.CurrentThread.ManagedThreadId.ToString("00")}");

            //// 參數設置為false
            //ManualResetEvent manualResetEvent = new ManualResetEvent(false);
            //ThreadPool.QueueUserWorkItem(p => 
            //{
            //    DoSomethingLong("啟動多線程");
            //    // 設置為true
            //    manualResetEvent.Set();
            //});
            //// 
            //manualResetEvent.WaitOne();
            //Console.WriteLine("等著QueueUserWorkItem完成后才執行");

            // SetWait();

            // ThreadPool實現線程的重用
            // ThreadPoolTest();

            // Thread
            ThreadTest();
            Console.WriteLine($"end ThreadId: {Thread.CurrentThread.ManagedThreadId.ToString("00")}");
            Console.ReadKey();
        }

        static void DoSomethingLong(string para)
        {
            Console.WriteLine($"{para}  ThreadId: {Thread.CurrentThread.ManagedThreadId.ToString("00")}");
        }

        /// 
        /// 設置線程池線程個數
        /// 
        static void SetThreadPool()
        {

            Console.WriteLine("************設置最多線程數和最少線程數****************");
            // 設置最大線程
            ThreadPool.SetMaxThreads(16, 16);
            // 設置最小線程
            ThreadPool.SetMinThreads(8, 8);

        }

        static void SetWait()
        {
            // 設置最大線程
            ThreadPool.SetMaxThreads(16, 16);
            // 設置最小線程
            ThreadPool.SetMinThreads(8, 8);
            ManualResetEvent manualResetEvent = new ManualResetEvent(false);
            for (int i = 0; i < 20; i++)
            {
                int k = i;
                ThreadPool.QueueUserWorkItem(p =>
                {
                    Console.WriteLine(k);
                    if (k < 18)
                    {
                        manualResetEvent.WaitOne();
                    }
                    else
                    {
                        // 設為true
                        manualResetEvent.Set();
                    }
                });
            }
            if (manualResetEvent.WaitOne())
            {
                Console.WriteLine("沒有死鎖、、、");
            }
            else
            {
                Console.WriteLine("發生死鎖、、、");
            }
        }

        /// 
        /// 測試ThreadPool線程重用
        /// 
        static void ThreadPoolTest()
        {
            // 線程重用
            ThreadPool.QueueUserWorkItem(t => DoSomethingLong("ThreadPool"));
            ThreadPool.QueueUserWorkItem(t => DoSomethingLong("ThreadPool"));
            ThreadPool.QueueUserWorkItem(t => DoSomethingLong("ThreadPool"));
            ThreadPool.QueueUserWorkItem(t => DoSomethingLong("ThreadPool"));
            ThreadPool.QueueUserWorkItem(t => DoSomethingLong("ThreadPool"));
            Thread.Sleep(10 * 1000);
            Console.WriteLine("前面的計算都完成了。。。。。。。。");
            ThreadPool.QueueUserWorkItem(t => DoSomethingLong("ThreadPool"));
            ThreadPool.QueueUserWorkItem(t => DoSomethingLong("ThreadPool"));
            ThreadPool.QueueUserWorkItem(t => DoSomethingLong("ThreadPool"));
            ThreadPool.QueueUserWorkItem(t => DoSomethingLong("ThreadPool"));
            ThreadPool.QueueUserWorkItem(t => DoSomethingLong("ThreadPool"));
        }

        /// 
        /// 測試Thread線程重用
        /// 
        static void ThreadTest()
        {
            for (int i = 0; i < 5; i++)
            {
                new Thread(() => DoSomethingLong("Threads")).Start();
            }
            Thread.Sleep(10 * 1000);
            Console.WriteLine("前面的計算都完成了。。。。。。。。");
            for (int i = 0; i < 5; i++)
            {
                new Thread(() => DoSomethingLong("btnThreads")).Start();
            }
        }
    }
}

原文鏈接：https://www.cnblogs.com/dotnet261010/p/9124380.html

上一篇：Matplotlib條形圖之分組條形圖和堆疊條形圖詳解_py
下一篇：使用Dockerfile實現數據卷的掛載問題(推薦)_doc

日本免费高清视频-国产福利视频导航-黄色在线播放国产-天天操天天操天天操天天操|www.shdianci.com

網站首頁編程語言正文

C#多線程之線程池ThreadPool用法_C#教程

目錄

一、ThreadPool

1、QueueUserWorkItem()

2、GetMaxThreads()

3、GetMinThreads()

4、SetMaxThreads()和SetMinThreads()

二、線程等待

三、線程重用

相關推薦

日本免费高清视频-国产福利视频导航-黄色在线播放国产-天天操天天操天天操天天操|www.shdianci.com

網站首頁 編程語言 正文

C#多線程之線程池ThreadPool用法_C#教程

目錄

一、ThreadPool

1、QueueUserWorkItem()

2、GetMaxThreads()

3、GetMinThreads()

4、SetMaxThreads()和SetMinThreads()

二、線程等待

三、線程重用

相關推薦

網站首頁編程語言正文