AI 助理
备案控制台
开发者社区 开发与运维 文章 正文

《CLR Via C# 第3版》笔记之（十八） - 线程池

2017-10-18 1047
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介：

利用线程池可以对线程进行有效的控制，使得线程能够更好的协作。

在我们实际使用线程时，应当尽量使用线程池来构造线程，避免直接new一个线程。

主要内容：

  • 控制资源消耗
  • 提高线程性能
  • 取消运行中的线程 

1. 控制资源消耗

线程池(ThreadPool)启动线程的方法很简单，和上一篇直接new一个线程类似，也有带参数和不带参数两种。

1
2
public  static  bool  QueueUserWorkItem(WaitCallback callBack);
public  static  bool  QueueUserWorkItem(WaitCallback callBack, object  state);

 

其中的WaitCallback委托定义如下：

1
public  delegate  void  WaitCallback( object  state);

 

那么，线程池是如何有效的控制系统资源的消耗的呢？

它的原理非常简单：

  • 线程池中维护一个请求队列，当应用程序有异步的请求时，将此请求(比如请求A)发送到线程池。
  • 线程池将请求A放入请求队列中，然后新建一个线程(比如线程A)来处理请求A。
  • 请求A处理完成后，线程池不会销毁线程A，而是使用线程A来处理请求队列中的下一个请求(比如请求B)。
  • 当请求过多时，线程池才会再新建一些线程来加快处理请求队列中的请求。（注1）
  • 当请求队列为空时，线程池会销毁一些空闲时间比较长的线程。（注2）

注1：保证所有的请求由少量线程处理，减少系统资源的消耗，同时减少了线程新建，销毁的次数。

注2：空闲时间多长才销毁线程是由CLR决定的，不同版本的CLR这个时间可能不同。

 

下面通过一个例子来看看，线程池是如何节约系统资源的。

首先看看直接new线程时，系统资源是如何变化的。

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
using  System;
using  System.Threading;
 
public  class  CLRviaCSharp_18
{
     static  void  Main( string [] args)
     {
         Console.WriteLine( "Main Thread" );
 
         for  ( int  i = 0; i < 100; i++)
         {
             Thread t = new  Thread(ThreadMethod);
             t.Start(i);
         }
 
         Console.ReadKey( true );
     }
 
     private  static  void  ThreadMethod( object  state)
     {
         Console.WriteLine( "This thread's state is {0}" , state);
         Thread.Sleep(2000);
     }
}

代码执行前，系统资源如下图。线程数和占用的内存见下图的红色框。

image

 

代码执行后，系统资源如下图。线程数和占用的内存见下图的红色框。

image

程序运行时，内存一下增加了100多MB，线程也增加了100多个。

 

在看看利用线程池来处理异步请求时，系统资源是如何变化的。

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
using  System;
using  System.Threading;
 
public  class  CLRviaCSharp_18
{
     static  void  Main( string [] args)
     {
         Console.WriteLine( "Main Thread" );
 
         for  ( int  i = 0; i < 100; i++)
         {
             ThreadPool.QueueUserWorkItem(ThreadMethod, i);
         }
 
         Console.ReadKey( true );
     }
 
     private  static  void  ThreadMethod( object  state)
     {
         Console.WriteLine( "This thread's state is {0}" , state);
         Thread.Sleep(2000);
     }
}

代码执行前，系统资源如下图。线程数和占用的内存见下图的红色框。

image

 

代码执行后，系统资源如下图。线程数和占用的内存见下图的红色框。

image

程序运行时，最忙时(刚开始请求队列中线程较多时)多了10个线程，随着请求队列中线程的较少，线程池最终只维持了2，3个线程，消耗的资源最多也就10几MB。

 

通过以上的对比，我们可以看出如果应用程序都采用线程池来管理线程的话，确实可以减轻系统的负担，更有效的利用系统资源，保证多个应用程序可以同时运行。

否则一个应用程序占用太多资源，其他应用程序只能等待。

当然，通过上面两个例子，我们也发现利用线程池的程序执行时间比较长。这就是控制资源的结果，使得应用程序的异步请求逐步处理。

 

2. 提高线程性能

线程虽然轻量(和进程相比)，但是毕竟也包含了一些信息(可参见上一篇中的线程开销)，所以如果多了也会消耗很多系统资源。

而通过主线程来创建子线程时，主线程的上下文信息还得拷贝一份再传入子线程，比如上面的例子中新建了100个线程，就得将上下文信息拷贝100遍。

在有些情况下，子线程并没有用到主线程的上下文信息，此时，我们就可以通过阻止上下文信息的流动(主线程-->子线程)来提高线程的性能。

 

下面的例子演示如何阻止和恢复上下文信息的传递。

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
using  System;
using  System.Threading;
using  System.Runtime.Remoting.Messaging;
 
public  class  CLRviaCSharp_18
{
     static  void  Main( string [] args)
     {
         Console.WriteLine( "Main Thread" );
         CallContext.LogicalSetData( "Info" , "Main Thread's Context info." );
 
         // 阻止上下文的传递
         ExecutionContext.SuppressFlow();
         ThreadPool.QueueUserWorkItem(ThreadMethod, "Thread 1" );
 
         // 恢复上下文的传递
         ExecutionContext.RestoreFlow();
         ThreadPool.QueueUserWorkItem(ThreadMethod, "Thread 2" );
 
         Console.ReadKey( true );
     }
 
     private  static  void  ThreadMethod( object  state)
     {
         Console.WriteLine(state + "'s Context Info is : "  + CallContext.LogicalGetData( "Info" ));
     }
}

运行结果如下：

image

 

3. 取消运行中的线程

3.1 取消线程

对于长时间运行的线程，如果不提供取消操作，那么它就会一直占用系统资源，直至运行完成。

这样的用户体验很糟糕，所以对于有可能运行很长时间的线程，应该提供取消的操作供用户选择。

线程的取消主要使用CancellationTokenSource。

下面通过例子来演示如何取消一个线程的运行。

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
using  System;
using  System.Threading;
 
public  class  CLRviaCSharp_18
{
     static  void  Main( string [] args)
     {
         Console.WriteLine( "Main Thread" );
         CancellationTokenSource cts = new  CancellationTokenSource();
         ThreadPool.QueueUserWorkItem(o => ThreadMethod(cts.Token));
 
         Console.WriteLine( "Press any key to cancel." );
         Console.ReadKey( true );
 
         // 取消线程的操作
         cts.Cancel();
 
         Console.ReadKey( true );
     }
 
     private  static  void  ThreadMethod(CancellationToken token)
     {
         do
         {
             // 线程取消前一直运行
             Console.WriteLine( "Now is : {0}" , DateTime.Now.ToString( "HH:mm:ss" ));
             Thread.Sleep(1000);
         } while  (!token.IsCancellationRequested);
 
         Console.WriteLine( "This thread is cancelled!" );
     }
}

只要输入任意键就可以取消线程。

 

3.2 取消线程时，注册一些额外的操作

主线程取消子线程后，可能需要进行一些操作来回收资源，释放对象等等。我们可以将这些操作注册到CancellationTokenSource的Token中，使得每个线程取消后都会执行这些操作。

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
using  System;
using  System.Threading;
 
public  class  CLRviaCSharp_18
{
     static  void  Main( string [] args)
     {
         Console.WriteLine( "Main Thread" );
         CancellationTokenSource cts = new  CancellationTokenSource();
         // 注册线程取消后的操作，执行操作的顺序与注册的顺利相反
         // 比如以下2个操作，第二个操作先执行
         cts.Token.Register(() => Console.WriteLine( "sub thread's object is disposed!" ));  // 后执行
         cts.Token.Register(() => Console.WriteLine( "sub thread's garbage is collected!" )); // 先执行
 
         ThreadPool.QueueUserWorkItem(o => ThreadMethod(cts.Token));
 
         Console.WriteLine( "Press any key to cancel." );
         Console.ReadKey( true );
 
         // 取消线程的操作
         cts.Cancel();
 
         Console.ReadKey( true );
     }
 
     private  static  void  ThreadMethod(CancellationToken token)
     {
         do
         {
             // 线程取消前一直运行
             Console.WriteLine( "Now is : {0}" , DateTime.Now.ToString( "HH:mm:ss" ));
             Thread.Sleep(1000);
         } while  (!token.IsCancellationRequested);
 
         Console.WriteLine( "This thread is cancelled!" );
     }
}

运行结果如下：（在子线程打印了五次时间后，键盘输入任意按键） 

image

 

3.3 禁止取消线程

为了防止某些线程被意外取消，可以通过CancellationToken.None属性来禁止某些线程被取消。

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
using  System;
using  System.Threading;
 
public  class  CLRviaCSharp_18
{
     static  void  Main( string [] args)
     {
         Console.WriteLine( "Main Thread" );
         CancellationTokenSource cts = new  CancellationTokenSource();
 
         // 线程"Thread 1"不会被取消
         ThreadPool.QueueUserWorkItem(o => ThreadMethod(CancellationToken.None, "Thread 1" ));
         // 线程"Thread 2"会被取消
         ThreadPool.QueueUserWorkItem(o => ThreadMethod(cts.Token, "Thread 2" ));
 
         Console.WriteLine( "Press any key to cancel." );
         Console.ReadKey( true );
 
         // 取消线程的操作
         cts.Cancel();
 
         Console.ReadKey( true );
     }
 
     private  static  void  ThreadMethod(CancellationToken token, object  state)
     {
         do
         {
             // 线程取消前一直运行
             Console.WriteLine(state + " Now is : {0}" , DateTime.Now.ToString( "HH:mm:ss" ));
             Thread.Sleep(1000);
         } while  (!token.IsCancellationRequested);
 
         Console.WriteLine(state + " is cancelled!" );
     }
}

运行结果如下：

image

 

3.4 关联多个取消操作

可以将多个取消操作关联起来，这样主线程可以很容易的检验是否发生了取消操作。

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
using  System;
using  System.Threading;
 
public  class  CLRviaCSharp_18
{
     static  void  Main( string [] args)
     {
         Console.WriteLine( "Main Thread" );
         CancellationTokenSource cts1= new  CancellationTokenSource();
         CancellationTokenSource cts2= new  CancellationTokenSource();
 
         ThreadPool.QueueUserWorkItem(o => ThreadMethod(cts1.Token, "Thread 1" ));
         ThreadPool.QueueUserWorkItem(o => ThreadMethod(cts2.Token, "Thread 2" ));
 
         // 将ctsLink与cts1和cts2关联起来
         CancellationTokenSource ctsLink = CancellationTokenSource.CreateLinkedTokenSource(cts1.Token, cts2.Token);
 
         Console.WriteLine( "Press any key to cancel." );
         Console.ReadKey( true );
 
         // 取消线程2的操作，cts2.IsCancellationRequested属性变为True
         // 同时ctsLink的IsCancellationRequested也变为True
         cts2.Cancel();
 
         // 通过检验ctsLink就可以知道是否有线程被取消
         if  (ctsLink.IsCancellationRequested)
             Console.WriteLine( "Some thread has been cancelled!" );
         else
             Console.WriteLine( "No thread has been cancelled!" );
 
         Console.ReadKey( true );
     }
 
     private  static  void  ThreadMethod(CancellationToken token, object  state)
     {
         do
         {
             // 线程取消前一直运行
             Console.WriteLine(state + " Now is : {0}" , DateTime.Now.ToString( "HH:mm:ss" ));
             Thread.Sleep(1000);
         } while  (!token.IsCancellationRequested);
 
         Console.WriteLine(state + " is cancelled!" );
     }
}
标签:  CLR via C#笔记


本文转自wang_yb博客园博客，原文链接：http://www.cnblogs.com/wang_yb/archive/2011/11/07/2239429.html，如需转载请自行联系原作者

文章标签：
C#
Java
.NET
关键词：
C#线程
C#笔记
笔记线程
C#线程池
clrviac#第3版线程
zting科技
目录
相关文章
土木林森
|
SQL 开发框架 安全
C#编程与多线程处理
【4月更文挑战第21天】探索C#多线程处理，提升程序性能与响应性。了解C#中的Thread、Task类及Async/Await关键字，掌握线程同步与安全，实践并发计算、网络服务及UI优化。跟随未来发展趋势，利用C#打造高效应用。
土木林森
333 3
大花爱编程
|
安全 编译器 C#
C#学习相关系列之多线程---lock线程锁的用法
C#学习相关系列之多线程---lock线程锁的用法
大花爱编程
239 1
大花爱编程
|
Java 调度 C#
C#学习系列相关之多线程（一）----常用多线程方法总结
C#学习系列相关之多线程（一）----常用多线程方法总结
大花爱编程
165 0
大花爱编程
|
C#
C#学习相关系列之多线程---ConfigureAwait的用法
C#学习相关系列之多线程---ConfigureAwait的用法
大花爱编程
376 0
陌陌谣
|
3月前
|
机器学习/深度学习 监控 算法
局域网行为监控软件 C# 多线程数据包捕获算法：基于 KMP 模式匹配的内容分析优化方案探索
本文探讨了一种结合KMP算法的多线程数据包捕获与分析方案，用于局域网行为监控。通过C#实现，该系统可高效检测敏感内容、管理URL访问、分析协议及审计日志。实验表明，相较于传统算法，KMP在处理大规模网络流量时效率显著提升。未来可在算法优化、多模式匹配及机器学习等领域进一步研究。
陌陌谣
89 0
小白学大数据
|
数据采集 XML JavaScript
C# 中 ScrapySharp 的多线程下载策略
C# 中 ScrapySharp 的多线程下载策略
小白学大数据
154 0
程序员小海绵
|
设计模式 缓存 Java
谷粒商城笔记+踩坑（14）——异步和线程池
初始化线程的4种方式、线程池详解、异步编排 CompletableFuture
程序员小海绵
309 0
谷粒商城笔记+踩坑（14）——异步和线程池
东方睿赢
|
C# 开发者
【C# 多线程编程陷阱揭秘】：小心！那些让你的程序瞬间崩溃的多线程数据同步异常问题，看完这篇你就能轻松应对！
【9月更文挑战第2天】
东方睿赢
508 4
你都不懂
|
11月前
|
算法 安全 测试技术
C#——刘铁猛笔记
C#——刘铁猛笔记
你都不懂
268 0
长梦
|
12月前
|
安全 数据库连接 API
C#一分钟浅谈：多线程编程入门
在现代软件开发中，多线程编程对于提升程序响应性和执行效率至关重要。本文从基础概念入手，详细探讨了C#中的多线程技术，包括线程创建、管理及常见问题的解决策略，如线程安全、死锁和资源泄露等，并通过具体示例帮助读者理解和应用这些技巧，适合初学者快速掌握C#多线程编程。
长梦
186 0