其中有意思的部分是由Monitor方法完成的。在这个方法中，会创建一个类级别的ManualResetEvent数组，该数组的大小和池将要服务的工作项目的数目一样。

　　注意

　　要记住的是，在这篇文章中，工作项目和线程并不是一件事情。工作项目是由线程完成的，但是在应用中，工作项目的数目可以比线程更多。当前runtime支持的线程池大小是30，因此如果提交超过30个工作项目到池中将自动令一些工作项目必须等待其它的工作项目完成。在这个例子中，如果有超过30个工作项目的话，那将永远不会运行，因为每个工作项目调用Listen，它将一直控制线程，直到Finish方法被调用。因此，为了确保runtime还有其它的线程作其它用途，WorkItems（工作项目）不要超过15个。

　　工作项目的数目可以通过QueueListener类的WorkItems属性设置，它的默认值是7。接着就会通过一个For循环来创建每个ManualResetEvent对象，并且将它们和一个新的EventState相联系。然后结果对象objState就会作为第二个参数传送到ThreadPool类的共享方法QueueUserWorkItem中。就象它的名字隐含的意思一样，该方法令工作项目以队列的形式送给runtime管理的线程池，以等待下一个工作线程完成它。第一个参数是用来指定在工作项目开始执行的时候需要回调的方法，在这里是Listen。通过传送EventState作为第二个参数，Listen方法可以接收该对象，并且如我们前面讨论的一样，使用里面的状态信息。在这里，状态包含有用来调试的线程名字和一个用来同步线程的ManualResetEvent对象。在循环完成后，指定数目的工作项目将会以队列的形式被线程池执行。此时线程将会不断地检查指定的队列以得到新信息。

　　在客户端最终调用Finish方法来完成执行时，首先会设置其private mFinished变量为True。Listen方法在每次循环时都会检查该变量，如果设置为True时，就会退出循环，释放线程并且返回到池中。接着Finish方法将会使用WaitHandle类的共享WaitAll方法阻塞，直到mEvs数组中的所有ManualReset事件对象都被设置为signaled状态（True）。如果超时值被传送给该方法时，就会使用可选的第二个参数，在反阻塞现有的线程前，会等待指定的时间。使用这种方法，就可以确保Finish方法将一直阻塞，直到每个工作线程已经完成Listen方法中的当前循环。值得一提的是，线程确实被返回到池中而没有被破坏。这样在下一次调用Monitor时，将会重新使用现有的线程，不会重新创建它们而带来系统开销。

　　对于使用QueueListener的客户来说，其实现如下面的代码所示：

Dim objQ As New QueueListener("ssosa", "tester")

objQ.WorkItems = 10
objQ.Monitor()

' Do other work here

objQ.Finish()

　　在初始化一个新的对象，并且传送它监听的机器名和队列，工作项目的数字就被设置好，并且调用Monitor方法。其后，客户端可以调用Finish方法来清除工作线程（可带超时参数）。

　　这个例子向你解释了如何使用ThreadPool类，不过它当然不是创建线程池以执行监视消息队列的唯一方法。例如，可以很容易地修改QueueListener来创建和跟踪类中的Thread对象数组，以实现线程池。接着Finish方法在设置mFinished标志后，就可以执行一个循环来监视IsAlive属性，以决定线程池何时耗尽，这时就无需使用ManualResetEvent对象了。此外，上面提到TLS技巧可以用来传送状态信息给线程。这个体系可让你更好地控制线程，实际上，当runtinme管理的线程已经很繁重或者需要更多的工作项目时，这个方法将是更好的。

上一页  [1] [2] [3] [4] [5] [6] [7]