ThreadPool 线程池

相关概念：

线程池可以看做容纳线程的容器；

一个应用程序最多只能有一个线程池；

ThreadPool静态类通过QueueUserWorkItem()方法将工作函数排入线程池；

每排入一个工作函数，就相当于请求创建一个线程；

线程池的作用：

线程池是为突然大量爆发的线程设计的，通过有限的几个固定线程为大量的操作服务，减少了创建和销毁线程所需的时间，从而提高效率。

如果一个线程的时间非常长，就没必要用线程池了(不是不能作长时间操作，而是不宜。)，况且我们还不能控制线程池中线程的开始、挂起、和中止。

什么时候使用ThreadPool？



ThreadPool 示例一 ：


ThreadPool_1.cs

using System;

using System.Text;

using System.Threading;

namespace 多线程

{

public class Example

{

public static void Main()

{

// Queue the task.

ThreadPool.QueueUserWorkItem(new WaitCallback(ThreadProc));

Console.WriteLine("Main thread does some work, then sleeps.");

Thread.Sleep(1000);

Console.WriteLine("Main thread exits.");

}

static void ThreadProc(Object stateInfo)

{

// No state object was passed to QueueUserWorkItem,

// so stateInfo is null.

Console.WriteLine("Hello from the thread pool.");

}

}

}

ThreadPool 示例二 ：


ThreadPool_2.cs

using System;

using System.Collections.Generic;

using System.Text;

using System.Threading;

namespace CS_Test

{

class ThreadPool_Demo

{

// 用于保存每个线程的计算结果

static int[] result = new int[10];

//注意：由于WaitCallback委托的声明带有参数，

// 所以将被调用的Fun方法必须带有参数，即：Fun(object obj)。

static void Fun(object obj)

{

int n = (int)obj;

//计算阶乘

int fac = 1;

for (int i = 1; i <= n; i++)

{

fac *= i;

}

//保存结果

result
= fac;

}

static void Main(string[] args)

{

//向线程池中排入9个工作线程

for (int i = 1; i <= 9 ; i++)

{

//QueueUserWorkItem()方法：将工作任务排入线程池。

ThreadPool.QueueUserWorkItem(new WaitCallback(Fun),i);

// Fun 表示要执行的方法(与WaitCallback委托的声明必须一致)。

// i 为传递给Fun方法的参数(obj将接受)。

}

//输出计算结果

for (int i = 1; i <= 9; i++)

{

Console.WriteLine("线程{0}: {0}! = {1}",i,result[i]);

}

}

}

}

ThreadPool的作用：



ThreadPool类型提供了5个简单的静态方法来获取和设置线程池的上限和下限，同时它额外提供了一个方法来让程序员获知当前可用的线程数量，下面是这五个方法的签名。

void ThreadPool.GetMaxThreads(out int workThreads, out int completionPortThreads); void ThreadPool.GetMinThreads(out int workThreads, out int completionPortThreads); bool ThreadPool.SetMaxThreads(int workThreads, int completionPortThreads); bool ThreadPool.SetMinThreads(int workThreads, int completionPortThreads); void ThreadPool.GetAvailableThreads(out int workThreads, out int completion PortThreads);