ThreadPool

创建线程需要时间。如果有不同的小任务要完成,就可以事先创建许多线程/在应完成这些任务时发出请求。不需要自己创建这样一个列表。

该列表由ThreadPool类托管。这个类会在需要时增减池中线程的线程数,直到最大的线程数。池中的最大线程数是可配置的。在双核CPU中,默认设置为1023 个工作线程和1000个I/O线程。也可以指定在创建线程池时应立即启动的最小线程数,以及线程池 中可用的最大线程数。如果有更多的作业要处理,线程池中线程的个数也达到了极限,最新的作业就要排队,且必须等待线程完成其任务。

下面的示例应用程序首先要读取工作线程和I/O线程的最大线程数,把这些信息写入控制台中。 接着在for循环中,调用ThreadPool.QueueUserWorkItem()方法,传递一个WaitCallback类型的委托, 把JobForAThread()方法陚予线程池中的线程。线程池收到这个请求后,就会从池中选择一个线程, 来调用该方法。如果线程池还没有运行,就会创建一个线程池,并启动第一个线程。如果线程池已经在运行,且有一个空闲线程来完成该任务,就把该作业传递给这个线程。

static void Main()
{
    int nWorkerThreads;
    int nCompletionPortThreads;
    ThreadPool.GetMaxThreads(out nWorkerThreads, out nCompletionPortThreads);
    Console.WriteLine("Max worker threads: {0}, " + "I/O completion threads: {1}",
    nWorkerThreads, nCompletionPortThreads);
    ; i < ; i++)
    {
        ThreadPool.QueueUserWorkItem(JobForAThread);
    }
    Thread.Sleep();
}
static void JobForAThread(object state)
{
    ; i < ; i++)
    {
        Console.WriteLine("loop {0}, running inside pooled thread {1}", i, Thread.CurrentThread.ManagedThreadId);
        Thread.Sleep();
    }
}

线程池使用起来很简单,但它有一些限制:

  • 线程池中的所有线程都是后台线程。如果进程的所有前台线程都结束了,所有的后台线程 就会停止。不能把入池的线程改为前台线程。
  • 不能给入池的线程设置优先级或名称。
  • 对于COM对象,入池的所有线程都是多线程单元(multithreaded apartment, MTA)线程。许 多COM对象都需要单线程单元(single-threaded apartment, MTA)线程。
  • 入池的线程只能用于时间较短的任务。如果线程要一直运行(如Word的拼写检杳器线程), 就应使用Thread类创建一个线程.

43、ThreadPool 、WaitHandle、原子操作InterLocked-LMLPHP

05-11 20:03