C#线程从陌生到熟悉(3)

今天我们来谈谈线程池:

应用程序可以有多个线程，这些线程在休眠状态中需要耗费大量时间来等待事件发生。其他线程可能进入睡眠状态，并且仅定期被唤醒以轮循更改或更新状态信息，然后再次进入休眠状态。为了简化对这些线程的管理，.NET框架为每个进程提供了一个线程池，一个线程池有若干个等待操作状态，当一个等待操作完成时，线程池中的辅助线程会执行回调函数。线程池中的线程由系统管理，程序员不需要费力于线程管理，可以集中精力处理应用程序任务。通过基础类库中的ThreadPool类提供一个线程池,该线程池可用于发送工作现,处理异步I/O,代表其他线程等待及处理计时器.ThreadPool类的所有方法都是静态方法.ThreadPool本身也是一个静态类.
我们来看看他的定义和一些常用的方法:
 public static class ThreadPool
{
 [SecuritySafeCritical]
        public static void GetAvailableThreads(out int workerThreads, out int completionPortThreads);
        [SecuritySafeCritical]
        public static void GetMaxThreads(out int workerThreads, out int completionPortThreads);
        [SecuritySafeCritical]
        public static void GetMinThreads(out int workerThreads, out int completionPortThreads);
        [SecuritySafeCritical]
        public static bool QueueUserWorkItem(WaitCallback callBack);
        [SecuritySafeCritical]
        public static bool QueueUserWorkItem(WaitCallback callBack, object state);
}
GetAvailableThreads这个方法返回的最大线程池线程数和当前活动线程数之间的差值。 参数 workerThreads: 可用辅助线程的数目。completionPortThreads: 可用异步 I/O 线程的数目。
GetMaxThreads方法获得当前由线程池维护的辅助线程的最大数目.参数 workerThreads: 线程池中辅助线程的最大数目。completionPortThreads: 当前由线程池维护的空闲异步 I/O 线程的最大数目。
GetMinThreads方法获得当前由线程池维护的空闲辅助线程的最小数目.参数 workerThreads: 当前由线程池维护的空闲辅助线程的最小数目.completionPortThreads: 当前由线程池维护的空闲异步 I/O 线程的最小数目。
QueueUserWorkItem方法将方法排入队列以便执行。参数callBack, 表示要执行的方法.state:包含方法所用数据的对象。
下面看个例子:

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading;

namespace ConsoleApplication6
{
    class Program
    {
        static void Main(string[] args)
        {
            Console.WriteLine("主线程进行异步条用");

            AutoResetEvent asyncOpIsDone = new AutoResetEvent(false);
            ThreadPool.QueueUserWorkItem(new WaitCallback((x) =>
            {

                Thread.Sleep(1000);
                Console.WriteLine("工作任务");

            }));
            string s="我的参数";
            ThreadPool.QueueUserWorkItem(new WaitCallback((x) =>
            {
               
                Thread.Sleep(2000);
                Console.WriteLine("工作任务1");
                Console.WriteLine(x);
               
            }), s);
            ThreadPool.QueueUserWorkItem(new WaitCallback(MyAsyncOperation), asyncOpIsDone);
            Console.WriteLine("主线程执行其他");
            Console.WriteLine("主线程等待任务处理结束");
            asyncOpIsDone.WaitOne();
        }
        static void MyAsyncOperation(Object state)
        {
           
            Thread.Sleep(5000);
            Console.WriteLine("工作任务2");
            ((AutoResetEvent)state).Set();
        }
    }
}

 运行的结果为

这里有个类为AutoResetEvent,他的作用是通知正在等待的线程已发生事件。他是从EventWaitHandle继承而来的!例子中分别用了两种不同的方式调用,第二种是可以传递参数的!工作线程1就传递了"我的参数"字符串!工作线程2运行完了会通知等待的线程已发生事件.这里AutoResetEvent初始化的时候首先将信号设成false,工作线程2如果调用成功,将被设成true. asyncOpIsDone.WaitOne()阻塞当前线程,直到收到信号!

再看下面的例子

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading;

namespace ConsoleApplication7
{
    class Program
    {
        static void Main(string[] args)
        {
            Console.WriteLine("\n当前线程的HashCode:{0}", Thread.CurrentThread.GetHashCode().ToString());
            Console.WriteLine("当前应用域的名字为:{0}", AppDomain.CurrentDomain.FriendlyName);
            int workerThreads;
            int completionPortThreads;

            AutoResetEvent asyncOpIsDone = new AutoResetEvent(false);//信号初始为空
            AutoResetEvent asyncOpIsDone2 = new AutoResetEvent(false);
            ThreadPool.QueueUserWorkItem(new WaitCallback(MyWork), asyncOpIsDone);
            ThreadPool.QueueUserWorkItem(new WaitCallback(MyWork1), asyncOpIsDone2);
            ThreadPool.GetMaxThreads(out workerThreads, out completionPortThreads);
            Console.WriteLine("得当前由线程池维护的辅助线程的最大数目:{0}", workerThreads);
            ThreadPool.GetMinThreads(out workerThreads, out completionPortThreads);
            Console.WriteLine("得当前由线程池维护的空闲辅助线程的最小数目:{0}", workerThreads);
            /*WaitHandle[] waithandles = new WaitHandle[2];
            waithandles[0] = asyncOpIsDone;
            waithandles[1] = asyncOpIsDone2;
            WaitHandle.WaitAll(waithandles);  */     
            //或者可以这样
            asyncOpIsDone.WaitOne();
            Console.WriteLine("MyWork结束");
            asyncOpIsDone2.WaitOne();
            Console.WriteLine("MyWork1结束");
        }
        static void MyWork(Object state)
        {
            Console.WriteLine("\n当前线程的HashCode:{0}", Thread.CurrentThread.GetHashCode().ToString());
            Console.WriteLine("当前应用域的名字为:{0}", AppDomain.CurrentDomain.FriendlyName);
            Thread.Sleep(2000);
            ((AutoResetEvent)state).Set();//表示工作已经完成
        }
        static void MyWork1(Object state)
        {
            Console.WriteLine("\n当前线程的HashCode:{0}", Thread.CurrentThread.GetHashCode().ToString());
            Console.WriteLine("当前应用域的名字为:{0}", AppDomain.CurrentDomain.FriendlyName);
            Thread.Sleep(1000);
            ((AutoResetEvent)state).Set();//表示工作已经完成
        }

    }
}

运行结果为

本例中可以详细看AutoRestEvent的用法MyWork1实际上先结束的,但是asyncOpIsDone需要等MyWork的信号!所以先输出了MyWork结束.这里还有一个东西我想说的就是WaitHandle,上面的例子已经给出了他的用法!他是AutoRsetEvent的基类.

还有ThreadPool有一个函数RegisterWaitForSingleObject这个函数还是满有意思的!我这里就不再给出例子了!

好了,今天就到这了!