public static bool QueueUserWorkItem(WaitCallback);

public static bool QueueUserWorkItem(WaitCallback, object);

using System;
using System.Collections;
using System.Threading;
namespace ThreadExample
{
 //這是用來(lái)保存信息的數(shù)據(jù)結(jié)構(gòu)，將作為參數(shù)被傳遞
 public class SomeState
 {
 public int Cookie;
 public SomeState(int iCookie)
 {
  Cookie = iCookie;
 }
 }

 public class Alpha
 {
public Hashtable HashCount;
public ManualResetEvent eventX;
public static int iCount = 0;
public static int iMaxCount = 0;

  public Alpha(int MaxCount) 
{
  HashCount = new Hashtable(MaxCount);
  iMaxCount = MaxCount;
}

//線程池里的線程將調(diào)用Beta()方法
public void Beta(Object state)
{
 //輸出當(dāng)前線程的hash編碼值和Cookie的值
  Console.WriteLine(" {0} {1} :", Thread.CurrentThread.GetHashCode(),((SomeState)state).Cookie);
  Console.WriteLine("HashCount.Count=={0}, Thread.CurrentThread.GetHashCode()=={1}", HashCount.Count, Thread.CurrentThread.GetHashCode());
  lock (HashCount) 
  {
 //如果當(dāng)前的Hash表中沒(méi)有當(dāng)前線程的Hash值，則添加之
 if (!HashCount.ContainsKey(Thread.CurrentThread.GetHashCode()))
   HashCount.Add (Thread.CurrentThread.GetHashCode(), 0);
  HashCount[Thread.CurrentThread.GetHashCode()] = 
   ((int)HashCount[Thread.CurrentThread.GetHashCode()])+1;
 }
   int iX = 2000;
   Thread.Sleep(iX);
   //Interlocked.Increment()操作是一個(gè)原子操作，具體請(qǐng)看下面說(shuō)明
   Interlocked.Increment(ref iCount);

   if (iCount == iMaxCount)
   {
  Console.WriteLine();
 Console.WriteLine("Setting eventX ");
 eventX.Set();
  }
 }
 }
  public class SimplePool
  {
   public static int Main(string[] args)
   {
    Console.WriteLine("Thread Pool Sample:");
    bool W2K = false;
    int MaxCount = 10;//允許線程池中運(yùn)行最多10個(gè)線程
    //新建ManualResetEvent對(duì)象并且初始化為無(wú)信號(hào)狀態(tài)
    ManualResetEvent eventX = new ManualResetEvent(false);
    Console.WriteLine("Queuing {0} items to Thread Pool", MaxCount);
    Alpha oAlpha = new Alpha(MaxCount); 
    //創(chuàng)建工作項(xiàng)
    //注意初始化oAlpha對(duì)象的eventX屬性
    oAlpha.eventX = eventX;
    Console.WriteLine("Queue to Thread Pool 0");
    try
    {
     //將工作項(xiàng)裝入線程池 
     //這里要用到Windows 2000以上版本才有的API，所以可能出現(xiàn)NotSupportException異常
     ThreadPool.QueueUserWorkItem(new WaitCallback(oAlpha.Beta), new SomeState(0));
     W2K = true;
    }
    catch (NotSupportedException)
    {
     Console.WriteLine("These API's may fail when called on a non-Windows 2000 system.");
     W2K = false;
    }
    if (W2K)//如果當(dāng)前系統(tǒng)支持ThreadPool的方法.
    {
     for (int iItem=1;iItem < MaxCount;iItem++)
     {
      //插入隊(duì)列元素
      Console.WriteLine("Queue to Thread Pool {0}", iItem);
      ThreadPool.QueueUserWorkItem(new WaitCallback(oAlpha.Beta), new SomeState(iItem));
     }
     Console.WriteLine("Waiting for Thread Pool to drain");
     //等待事件的完成，即線程調(diào)用ManualResetEvent.Set()方法
     eventX.WaitOne(Timeout.Infinite,true);
     //WaitOne()方法使調(diào)用它的線程等待直到eventX.Set()方法被調(diào)用
     Console.WriteLine("Thread Pool has been drained (Event fired)");
     Console.WriteLine();
     Console.WriteLine("Load across threads");
     foreach(object o in oAlpha.HashCount.Keys)
      Console.WriteLine("{0} {1}", o, oAlpha.HashCount[o]);
    }
    Console.ReadLine();
    return 0;
   }
  }
 }
}