VB.NET并行与分布式编程(6)-线程与内核同步[18]

一、RegisterWaitForSingleObject 方法

   RegisterWaitForSingleObject(WaitHandle, WaitOrTimerCallback, Object, Int32, Boolean)  注册一个等待 WaitHandle 的委托，并指定一个 32 位带符号整数来表示超时值（以毫秒为单位）。 
   RegisterWaitForSingleObject(WaitHandle, WaitOrTimerCallback, Object, Int64, Boolean)  注册一个等待 WaitHandle 的委托，并指定一个 64 位带符号整数来表示超时值（以毫秒为单位）。 
   RegisterWaitForSingleObject(WaitHandle, WaitOrTimerCallback, Object, TimeSpan, Boolean)  注册一个等待 WaitHandle 的委托，并指定一个 TimeSpan 值来表示超时时间。 
   RegisterWaitForSingleObject(WaitHandle, WaitOrTimerCallback, Object, UInt32, Boolean)  指定表示超时（以毫秒为单位）的 32 位无符号整数，注册一个委托等待 WaitHandle。 

 

将指定的委托排队到线程池。

 

 

 Public Shared Function RegisterWaitForSingleObject ( _
 waitObject As WaitHandle, _
 callBack As WaitOrTimerCallback, _
 state As Object, _
 millisecondsTimeOutInterval As Integer, _
 executeOnlyOnce As Boolean _
) As RegisteredWaitHandle
参数
waitObject
类型：System.Threading.WaitHandle
要注册的 WaitHandle。 使用 WaitHandle 而非 Mutex。

callBack
类型：System.Threading.WaitOrTimerCallback
waitObject 参数终止时调用的 WaitOrTimerCallback 委托。

state
类型：System.Object
传递给委托的对象。

millisecondsTimeOutInterval
类型：System.Int32
以毫秒为单位的超时。 如果 millisecondsTimeOutInterval 参数为 0（零），函数将测试对象的状态并立即返回。 如果 millisecondsTimeOutInterval 为 -1，则函数的超时间隔永远不过期。

executeOnlyOnce
类型：System.Boolean
如果为 true，表示在调用了委托后，线程将不再在 waitObject 参数上等待；如果为 false，表示每次完成等待操作后都重置计时器，直到注销等待。

 

 

 

当发生以下情况之一时，辅助线程将执行委托：

指定对象处于终止状态。

超时间隔已过期。

RegisterWaitForSingleObject 方法检查指定对象的 WaitHandle 的当前状态。 如果对象状态为非终止状态，则此方法将注册一个等待操作。 此等待操作由线程池中的一个线程来执行。 当对象状态变为终止或超时间隔已过期时，委托由辅助线程执行。 如果 timeOutInterval 参数不为 0（零），并且 executeOnlyOnce 参数为 false，则每当事件收到信号或超时间隔过期时都会重置计时器。

 

若要取消等待操作，请调用 RegisteredWaitHandle.Unregister 方法。

等待线程使用 Win32 WaitForMultipleObjects 函数来监视已注册的等待操作。 因此，如果必须在对 RegisterWaitForSingleObject 的多次调用中使用相同的本机操作系统句柄，则必须使用 Win32DuplicateHandle 函数重复该句柄。 请注意，不应为传递到 RegisterWaitForSingleObject 的事件对象发出脉冲，这是因为等待线程在重置前可能不会检测到该事件已终止。

返回前，函数将修改某些类型的同步对象的状态。 修改仅发生在其终止状态满足等待条件的对象上。 例如，信号量计数减少一。

二、WaitOrTimerCallback 委托
'声明
<ComVisibleAttribute(True)> _
Public Delegate Sub WaitOrTimerCallback ( _
 state As Object, _
 timedOut As Boolean _
)
参数
state
类型：System.Object
一个对象，包含回调方法在每次执行时要使用的信息。

timedOut
类型：System.Boolean
如果 WaitHandle 超时，则为 true；如果其终止，则为 false。

备注
--------------------------------------------------------------------------------

WaitOrTimerCallback 表示当已注册的等待句柄超时或终止时要执行的回调方法。 创建委托，方法是将回调方法传递给 WaitOrTimerCallback 构造函数。 您的方法必须具有此处所显示的签名。

通过将 WaitOrTimerCallback 委托和 WaitHandle 传递给 ThreadPool.RegisterWaitForSingleObject 创建已注册的等待句柄。 每次 WaitHandle 超时或终止时，执行您的回调方法。

[Visual Basic]

 注意 
Visual Basic 用户可以省略 WaitOrTimerCallback 构造函数，在向 RegisterWaitForSingleObject 传递回调方法时只需使用 AddressOf 运算符即可。 Visual Basic 将自动调用正确的委托构造函数。
 

如果要将信息传递给回调方法，则在创建已注册的等待句柄时，创建一个包含所需信息的对象并将它传递给 RegisterWaitForSingleObject。 每次执行您的回调方法时，state 参数都包含此对象。

 

 

三、Unregister方法
<ComVisibleAttribute(True)> _
Public Function Unregister ( _
 waitObject As WaitHandle _
) As Boolean
参数
waitObject
类型：System.Threading.WaitHandle
要发出信号的 WaitHandle。

返回值
类型：System.Boolean
如果函数成功，则为 true；否则为 false。

备注
--------------------------------------------------------------------------------

如果指定了 waitObject，只有在成功注销 RegisteredWaitHandle 之后它才会终止。 如果在 Unregister 执行时回调方法正在进行，则直到回调方法完成之后 waitObject 才会终止。 特别是，如果回调方法执行 Unregister，则直到回调方法完成之后 waitObject 才会终止。

 

 

Imports System
Imports System.Threading
Imports System.Runtime.InteropServices
Imports System.Diagnostics
Imports System.Diagnostics.ThreadState


Module Module1
    Dim jg As Long = 0
    Public Class TaskInfo
        Public Handle As RegisteredWaitHandle = Nothing
        Public OtherInfo As String = "default"
        Public ev As AutoResetEvent
    End Class


    <MTAThread()> _
    Sub Main()








        '定义AutoResetEvent和RegisteredWaitHandle对象
        Dim myHandle As RegisteredWaitHandle = Nothing


        Dim ti As New TaskInfo()
        ti.ev = New AutoResetEvent(False)
        ti.OtherInfo = "deepfuture test"
        '注册等待,等待线程的任务就是定时取计算结果，如果没有计算完成，就继续等待
        ti.Handle = ThreadPool.RegisterWaitForSingleObject( _
           ti.ev, _
           New WaitOrTimerCallback(AddressOf mythreadrun), _
           ti, _
           100, _
           False _
       )
        Console.Write("{0},开始执行线程，主线程{1}正在计算结果", Now.ToLongTimeString, Thread.CurrentThread.ManagedThreadId)
        '等待并执行其它代码
        For mynum = 1 To 100
            jg += mynum
            Thread.Sleep(10)
            Console.WriteLine("主线程{0}正在运行.....当前计算结果为{1}", Now.ToLongTimeString, jg)
        Next
        Console.WriteLine("主线程  " & Now.ToLongTimeString & "线程计算完毕!")
        '设置为终止状态，触发回调
        ti.ev.Set()
        Thread.Sleep(20)


    End Sub
    Public Sub mythreadrun(ByVal state As Object, ByVal timedOut As Boolean)
        '本线程的任务是的计算完成后显示结果，没计算完成时，做其它工作，
        '在这里其他工作就是显示一个"."
        Dim ti As TaskInfo = CType(state, TaskInfo)
        If timedOut Then
            '时间到，仍没计算完毕，为非终止状态 
            Console.WriteLine("等待时间到，计算没有完毕，继续等待...")
        Else
            If Not ti.Handle Is Nothing Then
                '已经终止
                ti.Handle.Unregister(Nothing)
            End If
            Console.WriteLine("主线程{0}运行完成.....读取最终计算结果为{1}", Now.ToLongTimeString, jg)
        End If
    End Sub
End Module