好得很程序员自学网

<tfoot draggable='sEl'></tfoot>

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#的委托机制可以很方便地实现异步编程。

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

dy("nrwz");

查看更多关于C#实现异步编程的方法的详细内容...

  阅读:53次