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

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

E)代码分析

上节代码是最简单的异步调用代码，即调用委托的 BeginInvoke 方法来开始执行方法，在主线程上执行一些工作，然后调用委托的 EndInvoke 方法。但是EndInvoke 直到异步调用完成之后才返回，因此可能会阻止调用线程（即主线程）。

a)? 声明异步方法?，必须与后面要使用的异步调用的方法一致?

???Delegate?Function?myAdds(ByVal?num?As?Integer,?<Out()>?ByRef?threadid?As?Integer)?As?Long???

b)定义IAsyncResult 对象，用来获取异步操作的状态

Dim myasyncresult As IAsyncResult

c)定义具体方法需要异步执行，其中mythreadrun要求与前面声明的异步方法一致(参数一致)

Dim?myadd?As?myAdds?=?New?myAdds(AddressOf?mythreadrun)

d) BeginInvoke 方法开始执行异步方法，将在NET线程池中分配线程执行,传入的参数就是mythreadrun的参数

myasyncresult?=?myadd.BeginInvoke(??????? Catch
??????????? Console.WriteLine(threadid & "号线程? " & Now.ToLongTimeString & "线程异常终止!")
??????????? '终止线程
??????????? Thread.CurrentThread.Abort()
??????? End Try
??????? Return jg
??? End Function

?

同时注意要Imports SystemImports System.ThreadingImports System.Runtime.InteropServicesImports System.DiagnosticsImports System.Diagnostics.ThreadStateModule Module1 '定义异步方法 Delegate Function myAdds(ByVal num As Integer, <Out()> ByRef threadid As Integer) As Long <MTAThread()> _ Sub Main() '定义IAsyncResult Dim myasyncresult As IAsyncResult '定义需要异步执行的方法 Dim myadd As myAdds = New myAdds(AddressOf mythreadrun) '定义计算结果存放处 Dim resultvalue As Long '异步线程调用号 Dim threadid As Integer '异步调用 myasyncresult = myadd.BeginInvoke(5000, threadid, Nothing, Nothing) Thread.Sleep(0) Console.Write("{0},开始执行线程，主线程{1}号正在等待", Now.ToLongTimeString, Thread.CurrentThread.ManagedThreadId) '等待并执行其它代码 While Not myasyncresult.AsyncWaitHandle.WaitOne(10) '执行其它代码输出一个点，同时以10毫秒为间隔等待工作线程完成 Console.Write(".") End While '异步调用完成，返回结果 resultvalue = myadd.EndInvoke(threadid, myasyncresult) '线程执行完毕 Console.WriteLine("{0}号线程计算结果为：{1}", threadid, resultvalue) End Sub Public Function mythreadrun(ByVal num As Integer, <Out()> ByRef threadid As Integer) As Long Dim mynum As Integer Dim jg As Long = 0 threadid = Thread.CurrentThread.ManagedThreadId Try For mynum = 1 To num jg += mynum Thread.Sleep(2) Next Console.WriteLine(threadid & "号线程 " & Now.ToLongTimeString & "线程运行完毕!") Catch Console.WriteLine(threadid & "号线程 " & Now.ToLongTimeString & "线程异常终止!") '终止线程 Thread.CurrentThread.Abort() End Try Return jg End FunctionEnd Module

??上面代码中的重点是：

?

?While Not myasyncresult.AsyncWaitHandle.WaitOne(10)
??????????? '执行其它代码输出一个点，以10毫秒为间隔等待工作线程完成
??????????? Console.Write(".")
??????? End While

?

我们通过myasyncresult.AsyncWaitHandle.WaitOne(10)进行等待，

等待10毫秒工作线程仍未完成，则执行主线程工作，输出一个点?

直到完成为止，可看出以下效果:

?