异步调用的两种方式

最近因为项目需要使用异步执行方法，特意查了一下这方面的资料，整理一下。

第一种方法使用的.net 2.0 所实现异步方法,可以做一些简单的异步处理,实现传入和传出参数.

第二种方法是使用自定义线程处理,适合处理复杂,可控的逻辑操作

下面是一个小小的示例,简单演示使用方法:

1. 使用BeginInvoke 实现异步方法调用
   

    1 using System;
    2 using System.Windows.Forms;
    3 using System.Threading;
    4 
    5 
    6 // 使用BeginInvoke 实现异步方法调用 (带传入,传出参数)
    7 public class BeginInvokeTest
    8 {
    9     //返回数据委托方法
   10     private delegate int MyMethod(int e);
   11 
   12     public void mian()
   13     {
   14         MyMethod myMethod = method;
   15         //调用异步方法,传入委托方法参数,完成后执行方法,委托实例
   16         //返回异步执行接口
   17         IAsyncResult asyncResult = myMethod.BeginInvoke(1000, MethodCompleted, myMethod);
   18 
   19     }
   20 
   21     //数据返回执行方法
   22     private int method(int sleepTime)
   23     {
   24         //做一些操作
   25         Thread.Sleep(sleepTime);
   26 
   27         //返回需要返回的数据,返回0
   28         return 0;
   29     }
   30 
   31     /// <summary>
   32     /// 异步完成执行方法
   33     /// </summary>
   34     /// <param name="asyncResult"></param>
   35     private void MethodCompleted(IAsyncResult asyncResult)
   36     {
   37         if (asyncResult == null)
   38         {
   39             return;
   40         }
   41 
   42         //接受返回数据 0
   43         int result = (asyncResult.AsyncState as MyMethod).EndInvoke(asyncResult);
   44     }
   45 
   46 }

   自定义线程实现异步方法调用 (带传入,传出参数)
   

       
    1 using System;
    2 using System.Windows.Forms;
    3 using System.Threading;
    4 
    5 //使用多线程方法 实现异步方法调用 (带传入,传出参数)
    6 namespace Wim.Tool
    7 {
    8     //定义返回数据委托
    9     public delegate void ResultEventHandler(int i);
    
        /// <summary>
        /// 数据库 调用主体方法
        /// </summary>
        public class WimSqlClient
        {
            /// <summary>
            /// 获取异步返回值处理方法
            /// </summary>
            /// <param name="i"></param>
            private static void ResultEventMethod(int i)
            {
                // TODO: 异步存储数据库返回值处理方法
            }
    
            /// <summary>
            /// 异步调用 SQL处理方法
            /// </summary>
            /// <param name="optCode"></param>
            /// <param name="userInfo"></param>
            /// <param name="optParam"></param>
            public void CreateAsyncService(string optCode, string userInfo, string optParam)
            {
    
                //实例化WimThreadState类，为线程提供参数
                WimThreadState tws = new WimThreadState(optCode, userInfo, optParam, new ResultEventHandler(ResultEventMethod));
    
                // 创建执行任务的线程，并执行
                Thread t = new Thread(new ThreadStart(tws.GetResult));
                t.IsBackground = true;
                t.Start();
            }
        }
    
        /// <summary>
        /// 数据库处理类
        /// </summary>
        public class WimThreadState
        {
            private const string siteInfo = "WIM";
            private ResultEventHandler resultEventHandler;
    
            //要用到的属性，也就是我们要传递的参数
            private string optCode;
            private string userInfo;
            private string optParam;
    
            //包含参数的构造函数
            public WimThreadState(string optCode, string userInfo, string optParam, ResultEventHandler resultEventHandler)
            {
                this.optCode = optCode;
                this.userInfo = userInfo;
                this.optParam = optParam;
                this.resultEventHandler = resultEventHandler;
            }
    
            /// <summary>
            /// 请求数据库,返回受影响行数
            /// </summary>
            public void GetResult()
            {
                // TODO: 需要异步处理的方法
            }
        }
    }