5.4 异步TCP编程(三)

5.4.3 使用异步方式调用同步方法

    .NET Framework提供了一种可以利用委托异步调用任何方法的技术,唯一的要求就是需要声明一个与要调用的方法具有相同签名的委托。对于任何一个方法,如果希望异步执行,最简单的方法就是通过调用委托的BeginInvoke方法开始异步执行,然后执行其他操作,最后调用委托的EndInvoke方法结束异步操作。由于EndInvoke直到异步操作完成后才返回,因此这种方法非常适合文件或网络操作。

1、声明与要调用的方法具有相同签名的委托

    下面的代码说明了如何声明一个与要调用的方法具有相同签名的委托:

1private BinaryReader br; 2... 3delegate void SendMessageDelegate(string message); 4private void SendMessage(string message) 5{ 6 try 7 { 8 bw.write(message); 9 bw.flush(); 10 } 11 catch 12 { 13 MessageBox.Show("发送失败!"); 14 } 15}

2、通过轮询方式检查异步调用是否完成

    声明和SendMessage方法具有相同签名的委托以后,公共语言运行时就会自动为该委托定义BeginInvoke方法和EndInvoke方法。然后就可以异步调用SendMessage方法了。

    调用BeginInvoke方法后,该方法会立即返回IAsyncResult类型的接口,从用户界面的服务线程中进行异步调用时,可以利用该接口的IsCompleted属性来通过轮询方式检查异步调用是否完成。在轮询过程中,BeginInvoke方法在ThreadPool中创建的线程会继续执行异步方法。例如:

1private bool needExit; 2... 3SendMessageDelegate d = new SendMessageDelegate(SendMessage); 4IAsyncResult result = d.BeginInvoke(message, null, null); 5while(result.IsCompleted == false) 6{ 7    if(needExit) 8    { 9        break; 10    } 11    Thread.Sleep(50); 12}

    当然,代码中只是演示了调用BeginInvoke后,如何查询异步操作是否完成,实际上也可以在调用BeginInvoke后,执行其他任何代码。

    BeginInvoke方法除了与要异步执行的方法具有相同的参数外,另外还有两个可选参数,第1个参数是一个AsyncCallback委托,该委托引用在异步调用完成时要调用的方法;第2个参数是一个用户定义的对象,该对象将消息传入回调方法。在这段代码中,由于用不到这两个参数,所以全部将其设置为null。

    程序调用BeginInvoke后,会立即返回一个可用于监视异步调用进度的IAsyncResult 接口,并继续执行BeginInvoke方法后面的代码,而不是等待异步调用完成。

    3、使用EndInvoke结束异步调用

    EndInvoke方法用于检索异步调用的结果,并结束异步调用。调用BeginInvoke之后,随时可以调用该方法。如果异步调用尚未完成,则EndInvoke会一直阻止该调用线程,直到异步调用完成。例如,在退出轮询后,可以直接通过下面的代码结束异步调用:

d.EndInvoke(result);

    与其他异步操作的End方法相同,调用EndInvoke方法后,在EndInvoke方法返回前,由于有可能会引起调用EndInvoke方法的线程阻塞,所以一般不要从服务于用户界面的线程直接调用该方法,否则会在异步操作完成前,给用户一个界面无反应的错觉。为了使界面操作流畅,可以将上面的语句该为用其它线程执行,例如:

1private struct SendMessageStates 2{ 3    public SendMessageDelagate d; 4    public IAsyncResult result; 5} 6private void AsyncSendMessage(string message) 7{ 8    SendMessageDelagate d = new SendMessageDelagate(SendMessage); 9    IAsyncResult result = d.BeginInvoke(message, null, null); 10    while(result.IsCompleted == false) 11    { 12        Thread.Sleep(50); 13    } 14    SendMessageStates states = new SendMessageStates(); 15    states.d = d; 16    states.result = result; 17    Thread t = new Thread(FinishAsyncSendMessage); 18    t.IsBackground = true; 19    t.Start(states); 20} 21private void FinishAsyncSendMessage(object obj) 22{ 23    SendMessageStates states = (SendMessageStates)obj; 24    states.d.EndInvoke(states.result); 25}

    4、在异步调用中传递多个参数

    在异步调用中,如果有多个参数信息,这些参数还可以使用out和ref关键字。例如:

1delegate void ReceiveMessageDelegate(out string receiveMessage); 2private void ReceiveMessage(out string receiveMessage) 3{ 4    receiveMessage = null; 5    try 6    { 7        receiveMessage = br.ReadString(); 8    } 9    catch(Exception ex) 10    { 11        MessageBox.Show(ex.message); 12    } 13} 14... 15ReceiveMessageDelegate d = new ReceiveMessageDelegate(ReceiveMessage); 16IAsyncResult result = d.BeginInvoke(out receiveString, null, null); 17while(result.IsCompleted == false) 18{ 19    Thread.Sleep(250); 20} 21d.EndInvoke(out receiveString, result);

    可见,使用异步方式调用同步方法,既实现了任何方法的异步调用,又可以轻而易举地解决异步调用中的同步问题,对于相对比较复杂的异步处理过程,这是首选的方法,也是最简单、最方便的方法。

点赞
收藏

评论区

加载中...

相关推荐

Spring @Async使用

@EnableAsync开启@Async注解功能一、功能@Async注解标记的方法可以使该方法异步的进行调用,如果在类上使用该注解,那么这个类的所有方法都会作为异步方法进行调用注意点,Async注解是基于SpringAop进行实现的,所以在相同的一个类中,方法互相调用是不会起到异步执行的作用的,这里多说一句,任何使用springaop代理实现的

Spring Boot使用@Async实现异步调用

异步调用对应的是同步调用,同步调用可以理解为按照定义的顺序依次执行,有序性;异步调用在执行的时候不需要等待上一个指令调用结束就可以继续执行。我们将在创建一个SpringBoot工程来说明。具体工程可以参考github代码https://github.com/UniqueDong/springbootstudy(https://www.osc

C# 1.0 新特性之异步委托(AP、APM)

Ø前言C异步委托也是属于异步编程中的一种,可以称为AsynchronousProgramming(异步编程)或者AsynchronousProgrammingModel(异步编程模型),因为这是实现异步编程的模式。委托是C1.0就有的特性,并且.NETv1.0同时也伴随有AsyncCallback、IAsyncResult

Play 2.0 用户指南 - 调用WebServices -- 针对Scala开发者

   PlayWSAPI   有时候我们需要在Play应用中调用外部HTTP服务。Play通过play.api.libs.ws.WS库提供支持,它提供了一种异步HTTP调用的方法。   任何play.api.libs.ws.WS的调用將返回Promise\play.api.libs.ws.Response

C# 创建线程的多种方式之异步调用基础知识

创建线程一种简单的方式是委托的异步调用,Delegate类提供了BeginInvoke方法,该方法可以传递委托类型定义的参数(所以BeginInvoke参数数量是可变的),另外还有2个固定的参数回调函数委托AsynsCallBack和类型Object(如果不使用可直接赋值为null)。BeginInvoke()的返回值为IAsynResult,通过它

Java BIO

同步与异步,阻塞与非阻塞同步:当前线程发起了一个调用或请求,然后当前线程需要等待该调用结束返回结果才能继续往下进行其他操作。异步:当前线程发起了一个调用或请求,然后当前线程不需等待调用的执行结果就可以继续往下执行(请求交由另一个线程去执行),之后可以通过被调用者的状态改变或者被调用者主动发出通知来获得执行结果