C#（99）：ThreadPool

int i = 0;
int j = 0;
//前面是辅助(也就是所谓的工作者)线程，后面是I/O线程
ThreadPool.GetMaxThreads(out i, out j);
Console.WriteLine(i.ToString() + "   " + j.ToString()); //默认都是1000

//获取空闲线程，由于现在没有使用异步线程，所以为空
ThreadPool.GetAvailableThreads(out i, out j);
Console.WriteLine(i.ToString() + "   " + j.ToString()); //默认都是1000

public static bool QueueUserWorkItem (System.Threading.WaitCallback callBack, object state);

static void Main(string[] args)
 {
     Person p = new Person(1, "刘备");
     //启动工作者线程
     ThreadPool.QueueUserWorkItem(new WaitCallback(RunWorkerThread), p);
 }

static void RunWorkerThread(object obj)
 {
     Thread.Sleep(200);
     Console.WriteLine("线程池线程开始!");
     Person p = obj as Person;
     Console.WriteLine(p.Name);
 }


 public class Person
 {
     public Person(int id, string name) { Id = id; Name = name; }
     public int Id { get; set; }
     public string Name { get; set; }
 }

public static System.Threading.RegisteredWaitHandle RegisterWaitForSingleObject (System.Threading.WaitHandle waitObject, System.Threading.WaitOrTimerCallback callBack, object state, int millisecondsTimeOutInterval, bool executeOnlyOnce);

// TaskInfo contains data that will be passed to the callback method.
public class TaskInfo
{
    public RegisteredWaitHandle Handle = null;
    public string OtherInfo = "default";
}


public static void Main(string[] args)
{
    // 主线程使用AutoResetEvent来给已注册的等待句柄发信号, 此等待句柄执行回调方法
    AutoResetEvent ev = new AutoResetEvent(false);

    TaskInfo ti = new TaskInfo();
    ti.OtherInfo = "First task";
    // 该任务的TaskInfo包括RegisterWaitForSingleObject返回的已注册的等待句柄。这允许在对象被发出一次信号时终止等待(参见WaitProc)。
    ti.Handle = ThreadPool.RegisterWaitForSingleObject(
        ev,
        new WaitOrTimerCallback(WaitProc),
        ti,
        1000,
        false
    );

    // 主线程等待三秒,为了演示队列中的线程超时，然后发信号.
    Thread.Sleep(3100);
    Console.WriteLine("Main thread signals.");
    ev.Set();//发信号

    // 主线程休眠，这应该给回调方法执行的时间。如果注释掉这一行，程序通常会在ThreadPool线程执行之前结束。
    Thread.Sleep(1000);
    / /如果您自己启动一个线程，您可以通过调用thread . join来等待它结束。此选项在线程池线程中不可用。
}

//当注册的等待时间超时，或者WaitHandle(在本例中是AutoResetEvent)发出信号时，回调方法执行。WaitProc在事件第一次发出信号时注销WaitHandle。.
public static void WaitProc(object state, bool timedOut)
{
    TaskInfo ti = (TaskInfo)state;

    string cause = "TIMED OUT";
    if (!timedOut) //如果Timeout为false，表示接收到的信号后执行的
    {
        cause = "SIGNALED";
        //如果回调方法执行的话是因为WaitHandle触发信号的话，则用反注册等待句柄来取消回调方法将来的执行。
        if (ti.Handle != null)
            ti.Handle.Unregister(null);//
    }

    Console.WriteLine("WaitProc( {0} ) executes on thread {1}; cause = {2}.",
        ti.OtherInfo, Thread.CurrentThread.GetHashCode().ToString(), cause);//超时后执行的
}