C#（五十六）之线程池

news2024/11/24 18:35:07

线程池：

线程池是一种多线程的形式，其中的任务被添加到队列中，并在创建线程时自动启动。

ThreadPool类：以下都是静态方法：（不需要new的）

GetAvailableThreads剩余空闲线程数

GetMaxThreads最多可用线程数，所有大于此数目的请求将保持排队状态，直到线程池线程变为可用

GetMinThreads检索线程池在新请求预测中维护的空闲线程数

QueueUserWorkItem启动线程池里得一个线程(队列的方式，如线程池暂时没空闲线程，则进入队列排队)

SetMaxThreads设置线程池中的最大线程数，多余在池外排队

SetMinThreads设置线程池最少需要保留的线程数，不足空线程补齐

一个应用程序只能有一个线程池

Public delegate void waitCallBack（object dataforfunction）；// 委托机制

以下三种情况不适宜使用线程池：

1：线程执行需要很长时间。

2：需要为线程制定详细的优先级

3：在执行过程中需要对线程进行操作，比如睡眠、挂起等。

线程池示例：

static void Main(string[] args)
        {
            for (int i = 0; i < 5; i++)
            {
                // 启动线程池的线程（委托）waitcallback
                System.Threading.ThreadPool.QueueUserWorkItem(new System.Threading.WaitCallback(TestThreadPool), new string[] { "drsw", "sfs", "sdfs" });
            }
           
            Console.ReadKey();
        }
 
        public static void TestThreadPool(object state)
        {
            string[] arry = state as string[]; //传过来的参数值
            int workerThreads = 0; // 正在工作线程
            int completionPortThreads = 0;// 完成工作线程
            System.Threading.ThreadPool.GetMaxThreads(out workerThreads, out completionPortThreads);
 
            Console.Write(DateTime.Now.ToString() + "--" + arry[0] + "----工作线程=" + workerThreads + "----完成工作线程=" + completionPortThreads + "
");
        }

输出：

2019/5/30 11:20:00--drsw----工作线程=1023----完成工作线程=1000

2019/5/30 11:20:00--drsw----工作线程=1023----完成工作线程=1000

2019/5/30 11:20:00--drsw----工作线程=1023----完成工作线程=1000

2019/5/30 11:20:00--drsw----工作线程=1023----完成工作线程=1000

2019/5/30 11:20:00--drsw----工作线程=1023----完成工作线程=1000

测试使用全部代码：

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Threading;
namespace threadPoool
{
    class Program
    {
        static void Main(string[] args)
        {
            for (int i = 0; i < 5; i++)
            {
                // 启动线程池的线程（委托）waitcallback
                System.Threading.ThreadPool.QueueUserWorkItem(new System.Threading.WaitCallback(TestThreadPool), new string[] { "drsw", "sfs", "sdfs" });
            }
           
            Console.ReadKey();
        }
        public static void TestThreadPool(object state)
        {
            string[] arry = state as string[]; //传过来的参数值
            int workerThreads = 0; // 正在工作线程
            int completionPortThreads = 0;// 完成工作线程
            System.Threading.ThreadPool.GetMaxThreads(out workerThreads, out completionPortThreads);
 
            Console.Write(DateTime.Now.ToString() + "--" + arry[0] + "----工作线程=" + workerThreads + "----完成工作线程=" + completionPortThreads + "
");
        }
    }
}