四联光电智能照明论坛

标题: 浅谈ThreadPool 线程池 [打印本页]
作者: admin    时间: 2016-11-7 15:34
标题: 浅谈ThreadPool 线程池
相关概念：
    线程池可以看做容纳线程的容器；
    一个应用程序最多只能有一个线程池；
    ThreadPool静态类通过QueueUserWorkItem()方法将工作函数排入线程池；
    每排入一个工作函数，就相当于请求创建一个线程；

线程池的作用：
线程池是为突然大量爆发的线程设计的，通过有限的几个固定线程为大量的操作服务，减少了创建和销毁线程所需的时间，从而提高效率。
如果一个线程的时间非常长，就没必要用线程池了(不是不能作长时间操作，而是不宜。)，况且我们还不能控制线程池中线程的开始、挂起、和中止。

什么时候使用ThreadPool？


ThreadPool 示例一 ：

  2. ThreadPool_1.cs

  4. using System;
  5. using System.Text;
  6. using System.Threading;

  8. namespace 多线程
  9. {
  10.     public class Example
  11.     {
  12.         public static void Main()
  13.         {
  14.             // Queue the task.
  15.             ThreadPool.QueueUserWorkItem(new WaitCallback(ThreadProc));

  17.             Console.WriteLine("Main thread does some work, then sleeps.");
  18.          
  19.             Thread.Sleep(1000);

  21.             Console.WriteLine("Main thread exits.");
  22.         }

  24.         static void ThreadProc(Object stateInfo)
  25.         {
  26.             // No state object was passed to QueueUserWorkItem,
  27.             // so stateInfo is null.
  28.             Console.WriteLine("Hello from the thread pool.");
  29.         }
  30.     }
  31. }
复制代码





ThreadPool 示例二 ：

  2. ThreadPool_2.cs

  4. using System;
  5. using System.Collections.Generic;
  6. using System.Text;
  7. using System.Threading;

  9. namespace CS_Test
  10. {
  11.     class ThreadPool_Demo
  12.     {
  13.         // 用于保存每个线程的计算结果
  14.         static int[] result = new int[10];


  17.         //注意：由于WaitCallback委托的声明带有参数，
  18.         //      所以将被调用的Fun方法必须带有参数，即：Fun(object obj)。
  19.         static void Fun(object obj)
  20.         {
  21.             int n = (int)obj;

  23.             //计算阶乘
  24.             int fac = 1;
  25.             for (int i = 1; i <= n; i++)
  26.             {
  27.                 fac *= i;
  28.             }
  29.             //保存结果
  30.             result[n] = fac;
  31.         }

  33.         static void Main(string[] args)
  34.         {
  35.             //向线程池中排入9个工作线程
  36.             for (int i = 1; i <= 9 ; i++)
  37.             {
  38.                 //QueueUserWorkItem()方法：将工作任务排入线程池。
  39.                 ThreadPool.QueueUserWorkItem(new WaitCallback(Fun),i);
  40.                 // Fun 表示要执行的方法(与WaitCallback委托的声明必须一致)。
  41.                 // i   为传递给Fun方法的参数(obj将接受)。
  42.             }

  44.             //输出计算结果
  45.             for (int i = 1; i <= 9; i++)
  46.             {
  47.                 Console.WriteLine("线程{0}: {0}! = {1}",i,result[i]);
  48.             }
  49.         }

  51.     }
  52. }
复制代码


ThreadPool的作用：





欢迎光临 四联光电智能照明论坛 (http://5xhome.com/) Powered by Discuz! X3.2