欢迎来到入门教程网!

C#教程

当前位置:主页 > 软件编程 > C#教程 >

C#实现异步编程的方法

来源:本站原创|时间:2020-01-10|栏目:C#教程|点击:

最近在我参与的几个.Net项目中都有用到异步编程,作为一名.Net小白,很有必要好好地学习一下C#异步编程。

什么是异步

异步指的就是不用阻塞当前线程来等待任务的完成,而是将任务扔到线程池中去执行,当前线程可以继续向下执行,直至其它线程将任务完成,并回调通知当前线程。整个任务从开始到结束都是异步完成的,不会阻塞当前线程。因此,异步很重要的一点就是,不会阻塞当前线程。

实现异步编程

在C#语言中,主要是通过委托来实现异步编程的,在委托类型中定义了两个方法BeginInvoke()和EndInvoke()。

/// <summary>
/// 开始执行异步操作.
/// </summary>
/// <param name="param">委托方法的参数</param>
/// <param name="callback"></param>
/// <param name="object"></param>
/// <returns></returns>
IAsyncResult BeginInvoke(int param, AsyncCallback callback, Object @object);

/// <summary>
/// 结束执行异步操作,并且返回异步操作结果.
/// </summary>
/// <param name="result"></param>
/// <returns>委托方法的返回类型</returns>
string EndInvoke(IAsyncResult result);

下面就通过一段代码来具体实现异步编程

/// <summary>
/// 定义一个委托类型
/// </summary>
public delegate string Del();

/// <summary>
/// 任务类
/// </summary>
public class TaskClass
{
  public static string SleepTask()
  {
    Console.WriteLine("异步线程(ThreadId = {0})开始执行睡眠任务,睡眠3s.\n", Thread.CurrentThread.ManagedThreadId);

    Thread.Sleep(3000);

    Console.WriteLine("异步线程(ThreadId = {0})苏醒,睡眠任务执行结束.\n", Thread.CurrentThread.ManagedThreadId);

    return "异步线程执行成功.\n";
  }
}
  
/// <summary>
/// 异步编程实现类(主线程不会阻塞)
/// </summary>
public class AsynCallbackClass
{
  public static string result;

  public static void Main(string[] args)
  {
    Console.WriteLine("主线程(ThreadId = {0})开始执行.\n", Thread.CurrentThread.ManagedThreadId);

    Del del = new Del(TaskClass.SleepTask);

    Console.WriteLine("主线程(ThreadId = {0})调用BeginInvoke()方法执行异步任务.\n", Thread.CurrentThread.ManagedThreadId);

    //开始执行异步操作,TaskClass.SleepTask无参数,Callback为定义的回调方法.
    del.BeginInvoke(Callback, null);

    Console.WriteLine("主线程(ThreadId = {0})继续执行.\n", Thread.CurrentThread.ManagedThreadId);

    Thread.Sleep(5000);

    //输出异步任务返回的结果
    Console.WriteLine(result);

    Console.WriteLine("主线程(ThreadId = {0})执行结束.\n", Thread.CurrentThread.ManagedThreadId);
  }

  /// <summary>
  /// 回调方法
  /// </summary>
  /// <param name="ar"></param>
  public static void Callback(IAsyncResult ar)
  {
    AsyncResult asyncResult = ar as AsyncResult;

    if (asyncResult == null) { return; }

    Del del = asyncResult.AsyncDelegate as Del;

    if (del == null) { return; }

    Console.WriteLine("回调方法中调用EndInvoke()方法,获取异步任务结果.\n", Thread.CurrentThread.ManagedThreadId);
    
    //结束执行异步操作,并返回异步任务结果.
    result = del.EndInvoke(ar);
  }
}

运行结果:

从运行结果中,我们可以发现主线程在调用了BeginInvoke()方法后,没有阻塞,而是继续向下执行,而且任务也确实由一个新的线程来执行,任务执行结束后,调用回调方法,在回调方法中调用EndInvoke()方法来获取任务执行结果。

总结

1. 在异步编程中,当前线程是不会被阻塞的。

2. C#的委托机制可以很方便地实现异步编程。

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持我们。

上一篇:C#多线程之Thread类详解

栏    目:C#教程

下一篇:C#实现FTP客户端的案例

本文标题:C#实现异步编程的方法

本文地址:https://www.xiuzhanwang.com/a1/C_jiaocheng/5551.html

网页制作CMS教程网络编程软件编程脚本语言数据库服务器

如果侵犯了您的权利,请与我们联系,我们将在24小时内进行处理、任何非本站因素导致的法律后果,本站均不负任何责任。

联系QQ:835971066 | 邮箱:835971066#qq.com(#换成@)

Copyright © 2002-2020 脚本教程网 版权所有