2024年3月9日发(作者:)

C# 线程池基础

池(Pool)是一个很常见的提高性能的方式。比如线程池连接池等,之所以有这

些池是因 为线程和数据库连接的创建和关闭是一种比较昂贵的行为。对于这种

昂贵的资源我们往往会考虑在一个池容器中放置一些资源,在用的时候去拿,在

不够的时候添 点,在用完就归还,这样就可以避免不断的创建资源和销毁资源。

如果您做过相关实验的话可能会觉得不以为然,似乎开1000个线程也用不了几

百毫秒。我们要这么想,对于一个高并发的环境来说,每一秒假设有100 个请

求,每个请求需要使用(开和关)10个线程,也就是一秒需要处理1000个线程

的开和关,每个线程独立堆栈1M,可以想象在这一秒中内存分配和回收是 多么

夸张,这个开销不能说不昂贵。

首先,要理解线程池线程分为两类工作线程和IO线程,可以单独设置最小线程

数和最大线程数:

Threads(2, 2);

Threads(4, 4);

最大线程数很好理解,就是线程池最多创建这些线程,如果最大4个线程,现在

这4个线程都在运行的话,后续进来的线程只能排队等待了。那么为什么有最 小

线程一说法呢?其实之所以使用线程池是不希望线程在创建后运行结束后理解

回收,这样的话以后要用的时候还需要创建,我们可以让线程池至少保留几个线

程, 即使没有线程在工作也保留。上述语句我们设置线程池一开始就保持2个

工作线程和2个IO线程,最大不超过4个线程。

至于线程池的使用相当简单先来看一段代码:

for (int i = 0; i < totalThreads; i++)

{

serWorkItem(o =>

{

(1000);

int a, b;

ilableThreads(out a, out b);

ine(("({0}/{1}) #{2} : {3}", a, b,

dThreadId,

ng("mm:ss")));

});

}

ine("Main thread finished");

ne();

代码里面用到了一个事先定义的静态字段:

static readonly int totalThreads = 10;

代码运行结果如下:

每一个线程都休眠一秒然后输出当前线程池可用的工作线程和IO线程以及当前

线程的托管ID和时间。我们通过这段代码可以发现线程池的几个特性:

1) 线程池中的线程都是后台线程,如果没有在主线程使用ReadLine的话,程

序马上会退出。

2) 线程池一开始就占用了2个线程,一秒后占用了4个线程,工作线程将会由

3-6四个线程来处理。

3) 线程池最多使用了4个工作线程和0个IO线程。

那么,我们如何知道线程池中的线程都运行结束了呢,可以想到上文用过的

Monitor结构:

Stopwatch sw = ew();

for (int i = 0; i < totalThreads; i++)

{

serWorkItem(o =>

{

(1000);

int a, b;

ilableThreads(out a, out b);

ine(("({0}/{1}) #{2} : {3}", a, b,

dThreadId,

ng("mm:ss")));

lock (locker)