C#多线程（二）

每次创建一个线程，都会花费几百微秒级别的时间来创建一个私有的局部栈，每个线程默认使用1M的内存。这个可以在使用Thread类的构造函数时设置：

[csharp] view plaincopyprint?

 

1. new Thread(new ThreadStart(Go), 2);  
2. new Thread(new ParameterizedThreadStart(Go("hello")), 3);  

提供的两种构造函数方式都提供了对应的设置线程局部栈的大小。线程池通过共享和回收线程的方式来分配这些内存，这样可以使多线程运行在一个非常细粒度级别上而不影响性能。这对于充分利用多核处理器，使用分而治之的方式进行密集型计算的程序中很有用。同时线程池维护一个所有同时运行的工作线程总数的上限，如果有过多的活动线程就会加重操作系统的负担，使诸如CPU缓存失效等问题，当达到这个上限后，就要进行排队。这个线程队列使得任意并发的应用成为可能，如Web服务器就是这种原理。

有多种方式进入线程池：

• 通过Task Parallel Library（.NET 4  TPL）
• 通过调用ThreadPool.QueueUserWorkItem
• 通过异步委托方式
• 使用BackgroundWorker

• 不能对放入线程池中的线程命名，这会使得调试更加困难
• 线程池中的线程总是后台线程
• 阻塞线程池中的线程困难引发额外的延迟

可以使用下面的方式查询当前线程是否在线程池中：

[csharp] view plaincopyprint?

 

1. CurrentTread.IsThreadPoolThread  

二、进入线程池

[csharp] view plaincopyprint?

 

1. static void Main(string[] args)  
2. {  
3.     Task.Factory.StartNew(Go);  
4.   
5.     Console.WriteLine("Is Thread Pool: " + Thread.CurrentThread.IsThreadPoolThread.ToString());  
6.     Console.ReadKey();  
7. }  
8. static void Go()  
9. {  
10.     Console.Write("Is Thread Pool: " + Thread.CurrentThread.IsThreadPoolThread.ToString());  
11. }  

Task.Factory.StartNew返回一个Task对象可以用来监控这个任务。

[csharp] view plaincopyprint?

 

1. static void Main(string[] args)  
2. {  
3.     Task<string> task = Task.Factory.StartNew<string>(Go);  
4.       
5.     Console.WriteLine("Is Thread Pool: " + Thread.CurrentThread.IsThreadPoolThread.ToString());  
6.   
7.     if (task.IsCompleted)  
8.     {  
9.         string result = task.Result;  
10.         Console.WriteLine(task.IsCompleted.ToString() +  result);  
11.     }  
12.     Console.ReadKey();  
13. }  
14. static string Go()  
15. {  
16.     return Thread.CurrentThread.IsThreadPoolThread.ToString();  
17. }  

如果在工作线程中出现异常，当获取Task的Result属性时会重新引发AggregateException异常，如果没有查询Result或者没有调用Wait方法，所有未处理的异常都会终止进程执行。

[csharp] view plaincopyprint?

 

1. static void Main()  
2. {  
3.   ThreadPool.QueueUserWorkItem (Go);  
4.   ThreadPool.QueueUserWorkItem (Go, 123);  
5.   Console.ReadLine();  
6. }  
7.    
8. static void Go (object data)   // data will be null with the first call.  
9. {  
10.   Console.WriteLine ("Hello from the thread pool! " + data);  
11. }  

[csharp] view plaincopyprint?

 

1. static void Main()  
2. {  
3.   Func<string, int> method = Work;  
4.   method.BeginInvoke ("test", Done, method);  
5.   // ...  
6.   //  
7. }  
8.    
9. static int Work (string s) { return s.Length; }  
10.    
11. static void Done (IAsyncResult cookie)  
12. {  
13.   var target = (Func<string, int>) cookie.AsyncState;  
14.   int result = target.EndInvoke (cookie);  
15.   Console.WriteLine ("String length is: " + result);  
16. }  

三、线程池的优化

[csharp] view plaincopyprint?

 

1. ThreadPool.SetMinThreads(50,50);