2012-06-29 23:00 1276人阅读 评论(0) 收藏 举报
 分类：
C/C++/C#/dotnet（126） 
 

目录(?)[+]

 

在应届生找工作的时候，多线程操作几乎是所有的公司都会问及的一个基本问题。

这里做了一个多线程操作的总结，这里总结了通过异步委托来实现多线程操作。

定义一个委托，是创建一个线程的最简单的方法，并且异步调用它。委托是方法的类型安全的引用。同时委托还智齿异步调用方法。

委托使用线程池来完成异步任务。

当自己的程序使用异步委托的时候，委托会自动创建ige执行线程的任务。委托使用线程池完成异步任务，所有的异步委托调用，都会通过调用系统线程池中的线程来完成调用异步任务。

在下面的简单例子中，我们定义了一个异步委托，并在每次输出的时候显示该函数运行在哪个线程中。

在异步委托中，可以使用三种技术来异步的调用委托。下面分别介绍三种调用异步委托的方法。

1. 投票判断异步委托是否完成

在委托中调用BeginInvoke()方法，返回IAsyncResult结果。程序的源代码如下：

  1. using System;
  2. using System.Collections.Generic;
  3. using System.Linq;
  4. using System.Text;
  5. using System.Threading;
  6. namespace AsyncDelegate
  7. {
  8. class Program
  9. {
  10. public delegate int TakeSomeTimeDelegate(int data,int ms);
  11. static void Main(string[] args)
  12. {
  13. TakeSomeTimeDelegate dl=TakeSomeTime;
  14. IAsyncResult ar=dl.BeginInvoke(1,200,null,null);
  15. while (!ar.IsCompleted)
  16. {
  17. Console.WriteLine(".");
  18. Console.WriteLine("Run in thread:" + Thread.CurrentThread.ManagedThreadId);
  19. Thread.Sleep(50);
  20. }
  21. int result = dl.EndInvoke(ar);
  22. Console.WriteLine("Result:{0}", result);
  23. }
  24. static int TakeSomeTime(int data, int ms)
  25. {
  26. Console.WriteLine("TakeSomeTime started!");
  27. Console.WriteLine("Run in thread:"+Thread.CurrentThread.ManagedThreadId);
  28. Thread.Sleep(ms);
  29. Console.WriteLine("TakeSomeTime Completed!");
  30. return ++data;
  31. }
  32. }
  33. }

该程序的输出结果如图：

可以看到主线程和异步委托线程是同时执行的。

如果在委托结束之前不等待委托完成其他任务就结束主线程，委托线程就会停止。

int result = dl.EndInvoke(ar); 这里的EndInvoke()函数会一直等在异步委托完成并在异步委托完成之前阻断主线程。这样就可以通过这个函数保证异步委托能够正确完成。

2. 等待句柄判断异步委托完成

通过AsyncWatiHandle属性，访问等待句柄。WaitOne()方法阻断当前线程，直到异步调用线程完成返回可以利用的句柄以后再执行当前线程。

程序：

  1. using System;
  2. using System.Collections.Generic;
  3. using System.Linq;
  4. using System.Text;
  5. using System.Threading;
  6. namespace AsyncDelegate
  7. {
  8. class Program
  9. {
  10. public delegate int TakeSomeTimeDelegate(int data,int ms);
  11. static void Main(string[] args)
  12. {
  13. TakeSomeTimeDelegate dl=TakeSomeTime;
  14. IAsyncResult ar=dl.BeginInvoke(1,200,null,null);
  15. while (true)
  16. {
  17. Console.WriteLine(".");
  18. Console.WriteLine("Run in thread:" + Thread.CurrentThread.ManagedThreadId);
  19. if (ar.AsyncWaitHandle.WaitOne(100, false))
  20. {
  21. Console.WriteLine("Can get the result now");
  22. break;
  23. }
  24. }
  25. //while (!ar.IsCompleted)
  26. //{
  27. //    Console.WriteLine(".");
  28. //    Console.WriteLine("Run in thread:" + Thread.CurrentThread.ManagedThreadId);
  29. //    Thread.Sleep(50);
  30. //}
  31. int result = dl.EndInvoke(ar);
  32. Console.WriteLine("Result:{0}", result);
  33. }
  34. static int TakeSomeTime(int data, int ms)
  35. {
  36. Console.WriteLine("TakeSomeTime started!");
  37. Console.WriteLine("Run in thread:"+Thread.CurrentThread.ManagedThreadId);
  38. Thread.Sleep(ms);
  39. Console.WriteLine("TakeSomeTime Completed!");
  40. return ++data;
  41. }
  42. }
  43. }

运行结果：

ar.AsyncWaitHandle.WaitOne()阻断了当前线程， 直到异步调用线程完成获得可以利用的句柄以后再次执行当前线程。

3. 利用异步回调函数判断异步调用线程是否结束

回调函数的操作比较复杂， 而且对于程序的理解和维护造成非常大的困难。所以一般情况下能不用回调函数就不要使用回调函数。

使用回调函数，必须注意这个函数从委托线程中调用，而不是从主线程中调用回调函数。

  1. using System;
  2. using System.Collections.Generic;
  3. using System.Linq;
  4. using System.Text;
  5. using System.Threading;
  6. namespace AsyncDelegate
  7. {
  8. class Program
  9. {
  10. public delegate int TakeSomeTimeDelegate(int data,int ms);
  11. static void Main(string[] args)
  12. {
  13. TakeSomeTimeDelegate dl=TakeSomeTime;
  14. IAsyncResult ar = dl.BeginInvoke(1, 200, TakeSomeTimeCompleted, dl);
  15. for (int i = 0; i < 10;i++ )
  16. {
  17. Console.WriteLine(".");
  18. Console.WriteLine("Run in thread:" + Thread.CurrentThread.ManagedThreadId);
  19. Thread.Sleep(50);
  20. }
  21. //int result = dl.EndInvoke(ar);
  22. //Console.WriteLine("Result:{0}", result);
  23. }
  24. static int TakeSomeTime(int data, int ms)
  25. {
  26. Console.WriteLine("TakeSomeTime started!");
  27. Console.WriteLine("Run in thread:"+Thread.CurrentThread.ManagedThreadId);
  28. Thread.Sleep(ms);
  29. Console.WriteLine("TakeSomeTime Completed!");
  30. return ++data;
  31. }
  32. static void TakeSomeTimeCompleted(IAsyncResult ar)
  33. {
  34. if (ar==null)
  35. {
  36. throw new ArgumentNullException("ar");
  37. }
  38. TakeSomeTimeDelegate dl = ar.AsyncState as TakeSomeTimeDelegate;
  39. int result = dl.EndInvoke(ar);
  40. Console.WriteLine("result : {0}", result);
  41. //Console.WriteLine("Run in thread:" + Thread.CurrentThread.ManagedThreadId);
  42. }
  43. }
  44. }

运行结果：

 
 

最新文章

  1. winform 实现pdf浏览
  2. memcached的最佳实践方案（转）
  3. C#中List和数组之间的转换
  4. dict-字典功能介绍
  5. CDN网络架构
  6. centos7安装svn
  7. .Net Core实现记录接口执行时间的中间件
  8. nodejs在windows下的安装配置(使用NVM的方式)
  9. 可在广域网部署运行的即时通讯系统 -- GGTalk总览（附源码下载）
  10. Oracle 删除重复数据只留一条（转）
  11. 挖坑:handoop2.6 开启kerberos(全流程学习记录)
  12. json和pickle，XML
  13. Jmeter（三十六）纵横并发、限制QPS
  14. python基础学习22----协程
  15. 001.YUM源服务端搭建
  16. ssl证书生成与验证
  17. FIREDAC的TFDJSONDataSets和TFDJSONDeltas查询和提交数据
  18. BZOJ4939 Ynoi2016掉进兔子洞（莫队+bitset）
  19. win7无法登陆linux samba共享
  20. Androidstudio与unity交互踩坑（黑屏问题）

热门文章

  1. Qt分割线
  2. index方法用于数据集的强制索引操作
  3. Linux下c开发 之 线程通信
  4. PAT甲级——A1074 Reversing Linked List
  5. 编写函数处理user_list，新方法
  6. conan本地安装包
  7. 2019-9-2-C＃判断文件属于文本或二进制
  8. 深度学习（二十六）Network In Network学习笔记
  9. JSOI 2016 扭动的字符串
  10. 3、mysql读写性能优化方法