C#使用delegate异步执行方法


在另外一个线程执行一个函数有很多种方法,这里讨论的是使用delegate的BeginInvoke方法,它的好处是在另一个线程中调用了函数,而且不用花费太多的开销。

下面是使用delegate异步执行方法的示例:

[csharp]
  1. class Program  
  2. {  
  3.   static void Main(string[] args)  
  4.   {  
  5.     object syncObject = new object();  
  6.     Test test = new Test();  
  7.     int index = 0;  
  8.     AutoResetEvent signal = new AutoResetEvent(false);  
  9.     for (int i = 0; i < 10; i++)  
  10.     {  
  11.       test.BeginDoAction(delegate(object sender, EventArgs e)  
  12.                          {  
  13.                            lock (syncObject)  
  14.                            {  
  15.                              Interlocked.Increment(ref index);  
  16.                              if (index == 10)  
  17.                                signal.Set();  
  18.                              Console.WriteLine("Receive result.");  
  19.                            }  
  20.                          });  
  21.     }  
  22.     Console.WriteLine("Waiting signal.");  
  23.     signal.WaitOne();  
  24.     Console.WriteLine("Signaled.");  
  25.   
  26.     Console.ReadLine();  
  27.   }  
  28. }  
  29.   
  30. public delegate int GetDelegate();  
  31.   
  32. class Test  
  33. {  
  34.   private EventHandler<EventArgs> callbackCompleted;  
  35.   
  36.   public void BeginDoAction(EventHandler<EventArgs> pCallbackCompleted)  
  37.   {  
  38.     Console.WriteLine("Begin do action.");  
  39.     callbackCompleted = pCallbackCompleted;  
  40.     AsyncCallback callback = OnCompleted;  
  41.     GetDelegate getDelegate = DoAction;  
  42.     getDelegate.BeginInvoke(callback, null);  
  43.   }  
  44.   
  45.   public int DoAction()  
  46.   {  
  47.     Console.WriteLine("Do action");  
  48.     Thread.Sleep(20000);  
  49.     return 1;  
  50.   }  
  51.   
  52.   private void OnCompleted(IAsyncResult result)  
  53.   {  
  54.     GetDelegate getDelegate = ((AsyncResult)result).AsyncDelegate as GetDelegate;  
  55.     int print = getDelegate.EndInvoke(result);  
  56.     if (callbackCompleted != null)  
  57.       callbackCompleted(this, EventArgs.Empty);  
  58.   }  
  59. }  
最终显示结果如下,说明函数被异步调用。


delegate是在另一个线程上异步执行一个方法的一种方式,但是它的使用也有一定的局限,由于delegate实际上是使用thread pool进行异步执行的,因此thread pool本身就成了这种调用方式的制约,比方说thread pool的尺寸或者其所能执行的线程数等等。因此并不是所有的异步方法调用都适合用delegate方式调用。

相关内容