教程(视频,书籍)下载:  ASP.NET AutoCAD 数据库 C# ASP java photoshop 网页设计 delphi 3dmax Flash C++ VB 张孝祥 实例   更多请进入BIBIDU搜索

　Dim evs As ManualResetEvent

　' Cast the state into the event
　evs = state.ResetEvent

　' Set the priority and name
　Thread.CurrentThread.Priority = ThreadPriority.BelowNormal
　Try
　　If Not state.ThreadName Is Nothing Then
　　　Thread.CurrentThread.Name = state.ThreadName
　　End If
　Catch e As Exception
　　' Thread name can only be set once
　　' Don't set it and get out
　End Try

　'Console.WriteLine("Listen {0} ", state.ThreadName)
　Try
　' Set the path property on the MessageQueue object, assume private in this 　case
　　objMQ.Path = mstrMachine & "\private$\" & mstrQueue
　　' Repeat until Interrupt received
　　While True
　　Try
　　　' Sleep in order to catch the interrupt if it has been thrown
　　　Thread.CurrentThread.Sleep(100)

　　　' Set the Message object equal to the result from the receive function
　　　' Will block for 1 second if a message is not received
　　　objMsg = objMQ.Receive(New TimeSpan(0, 0, 0, 1))

　　　' Message found so signal the event to say we're working
　　　evs.Reset()
　　　' Processing the message
　　　ProcessMsg(objMsg)
　　　' Done processing

　　Catch e As ThreadInterruptedException
　　　' Catch the ThreadInterrupt from the main thread and exit
　　　Exit While
　　Catch excp As MessageQueueException
　　　' Catch any exceptions thrown in receive
　　　' Probable timeout
　　Finally
　　　' Console.WriteLine("Setting Event " & 　　　Thread.CurrentThread.GetHashCode())
　　　' Done with this iteration of the loop so set the event
　　　evs.Set()
　　End Try

　　' If finished then exit thread
　　If mFinished Then
　　　'console.WriteLine("exiting " & thread.CurrentThread.GetHashCode)
　　　Exit While
　　End If

　End While

　Catch e As ThreadInterruptedException
　　' Catch the ThreadInterrupt from the main thread and exit
　End Try

End Sub

　Private Sub ProcessMsg(ByVal pMsg As Message)
　　' Here is where we would process the message
　End Sub

　Public Sub Monitor()
　　Dim intItem As Integer
　　Dim objState As EventState

　　ReDim mEvs(mWorkItems)
　　mFinished = False

　　'Console.WriteLine("Queuing {0} items to Thread Pool", mWorkItems)

　　For intItem = 0 To mWorkItems - 1
　　　'Console.WriteLine("Queue to Thread Pool {0}", intItem)
　　　mEvs(intItem) = New ManualResetEvent(False)
　　　objState = New EventState(mEvs(intItem), "Worker " & intItem)
　　　ThreadPool.QueueUserWorkItem(New WaitCallback(AddressOf Me.Listen), _ objState)
　　Next

　End Sub

　Public Sub Finish(Optional ByVal pTimeout As Integer = 0)
　　'Console.WriteLine("Waiting for Thread Pool to drain")
　　' Make sure everyone gets through the last iteration
　　mFinished = True
　　' Block until all have been set
　　If pTimeout = 0 Then
　　　WaitHandle.WaitAll(mEvs) ' Waiting until all threads signal that they are done.
　　Else
　　　WaitHandle.WaitAll(mEvs, pTimeout, True)
　　End If
　　　'Console.WriteLine("Thread Pool has been drained (Event fired)")
　　End Sub

End Class

　　要注意该列表包含有两个类：EventState，它是一个protected的子类，还有QueueListener。EventState包含有一个称为ResetEvent的字段，它的类型是ManualResetEvent，用来确保所有的工作线程可以无中断地完成它的工作，这是通过使用ResetEvent字段得到其状态。该类还包含有一个ThreadName字段，用来设置与该类相关的线程的名字，以便作调试用。