5.4 异步TCP编程(三)

Wesley13
• 阅读 146

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

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

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

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

private BinaryReader br;
...
delegate void SendMessageDelegate(string message);
private void SendMessage(string message)
{
    try
    {
        bw.write(message);
        bw.flush();
    }
    catch
    {
        MessageBox.Show("发送失败!");
    }
}

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

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

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

private bool needExit;
...
SendMessageDelegate d = new SendMessageDelegate(SendMessage);
IAsyncResult result = d.BeginInvoke(message, null, null);
while(result.IsCompleted == false)
{
    if(needExit)
    {
        break;
    }
    Thread.Sleep(50);
}

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

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

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

    3、使用EndInvoke结束异步调用

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

d.EndInvoke(result);

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

private struct SendMessageStates
{
    public SendMessageDelagate d;
    public IAsyncResult result;
}
private void AsyncSendMessage(string message)
{
    SendMessageDelagate d = new SendMessageDelagate(SendMessage);
    IAsyncResult result = d.BeginInvoke(message, null, null);
    while(result.IsCompleted == false)
    {
        Thread.Sleep(50);
    }
    SendMessageStates states = new SendMessageStates();
    states.d = d;
    states.result = result;
    Thread t = new Thread(FinishAsyncSendMessage);
    t.IsBackground = true;
    t.Start(states);
}
private void FinishAsyncSendMessage(object obj)
{
    SendMessageStates states = (SendMessageStates)obj;
    states.d.EndInvoke(states.result);
}

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

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

delegate void ReceiveMessageDelegate(out string receiveMessage);
private void ReceiveMessage(out string receiveMessage)
{
    receiveMessage = null;
    try
    {
        receiveMessage = br.ReadString();
    }
    catch(Exception ex)
    {
        MessageBox.Show(ex.message);
    }
}
...
ReceiveMessageDelegate d = new ReceiveMessageDelegate(ReceiveMessage);
IAsyncResult result = d.BeginInvoke(out receiveString, null, null);
while(result.IsCompleted == false)
{
    Thread.Sleep(250);
}
d.EndInvoke(out receiveString, result);

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

点赞
收藏
评论区
推荐文章
Stella981 Stella981
1年前
Spring @Async使用
@EnableAsync开启@Async注解功能 一、功能 @Async注解标记的方法可以使该方法异步的进行调用,如果在类上使用该注解,那么这个类的所有方法都会作为异步方法进行调用 注意点,Async注解是基于SpringAop进行实现的,所以在相同的一个类中,方法互相调用是不会起到异步执行的作用的,这里多说一句,任何使用spring aop代理实现的
Stella981 Stella981
1年前
Spring Boot使用@Async实现异步调用
异步调用对应的是同步调用,同步调用可以理解为按照定义的顺序依次执行,有序性;异步调用在执行的时候不需要等待上一个指令调用结束就可以继续执行。 我们将在创建一个 Spring Boot 工程来说明。具体工程可以参考github代码 [https://github.com/UniqueDong/springboot-study](https://www.osc
Stella981 Stella981
1年前
Linux网络IO模型
### **同步和异步,阻塞和非阻塞** #### **_同步和异步_** **关注的是结果消息的通信机制** 同步:同步的意思就是调用方需要主动等待结果的返回 异步:异步的意思就是不需要主动等待结果的返回,而是通过其他手段比如,状态通知,回调函数等。 #### **_阻塞和非阻塞_** **主要关注的是等待结果返回调用方的状态** 阻塞:是指
Wesley13 Wesley13
1年前
C# 1.0 新特性之异步委托(AP、APM)
Ø 前言 C# 异步委托也是属于异步编程中的一种,可以称为 Asynchronous Programming(异步编程)或者 Asynchronous Programming Model(异步编程模型),因为这是实现异步编程的模式。委托是 C#1.0 就有的特性,并且 .NET v1.0 同时也伴随有 AsyncCallback、IAsyncResult
可莉 可莉
1年前
2019.9.22 Tomcat的三种运行模式 (BIO,NIO,AIO也叫apr)
**1****、同步****概念:** * 同步 : 自己亲自出马持银行卡到银行取钱(使用同步IO时,Java自己处理IO读写)。 * 异步 : 委托一小弟拿银行卡到银行取钱,然后给你(使用异步IO时,Java将IO读写委托给OS处理,需要将数据缓冲区地址和大小传给OS(银行卡和密码),OS需要支持异步IO操作API)。 * 阻塞 : ATM排
Stella981 Stella981
1年前
Excel催化剂开源第8波
在VSTO开发过程中,因其和普通的Winform开发有点差别,具体细节笔者也说不清楚,大概是VSTO的插件是寄生在Excel中,不属于独立的进程之类的,其异步方法调用时,未能如Winform那样直接用await async异步方法就结束,仍需要再作简单的处理。 ### 使用场景 在Excel上直接使用异步方法,貌似有上述提及的问题,不像Winform程序
Wesley13 Wesley13
1年前
Java BIO
同步与异步,阻塞与非阻塞 ------------ **同步**:当前线程发起了一个调用或请求,然后当前线程需要等待该调用结束返回结果才能继续往下进行其他操作。 **异步**:当前线程发起了一个调用或请求,然后当前线程不需等待调用的执行结果就可以继续往下执行(请求交由另一个线程去执行),之后可以通过被调用者的状态改变或者被调用者主动发出通知来获得执行结果
Wesley13 Wesley13
1年前
C#中委托和事件的区别
大致来说,委托是一个类,该类内部维护着一个字段,指向一个方法。事件可以被看作一个委托类型的变量,通过事件注册、取消多个委托或方法。本篇分别通过委托和事件执行多个方法,从中体会两者的区别。 □ 通过委托执行方法 class Program { static void Main(string[] args) {
Wesley13 Wesley13
1年前
5.4 异步TCP编程(二)
    **5.4.2 异步TCP应用编程的一般方法(本节可以忽略)**     使用异步TCP编程时,除了套接字有对应的异步操作方式外,_TcpListener_和_TcpClient_类均提供了返回结果为_IAsyncResult_类型的异步操作的方法。     **1、BeginAcceptTcpClient方法和EndAcceptTcpClien
Stella981 Stella981
1年前
Spring 异步调用,多线程,一行代码实现
**Spring 异步调用,多线程** =================== * **概述** * **快速入门** * **异步回调** * **异步异常处理** * **自定义执行器** * * * 1、概述 ---- * * * 在日常开发中,我们的逻辑都是同步调用,顺序
Wesley13 Wesley13
1年前
PHP实现异步调用方法研究
浏览器和服务器之间是通过 HTTP 协议进行连接通讯的。这是一种基于请求和响应模型的协议。浏览器通过 URL 向服务器发起请求,Web 服务器接收到请求,执行一段程序,然后做出响应,发送相应的html代码给客户端。 这就有了一个问题,Web 服务器执行一段程序,可能几毫秒就完成,也可能几分钟都完不成。如果程序执行缓慢,用户可能没有耐心等下去,就关闭浏览器了