1 using System;
2 using System.Collections.Generic;
3 using System.Linq;
4 using System.Text;
5 using System.Threading;
6 using System.Runtime.Remoting.Messaging;
7
8 namespace ThreadExample
9 {
10 class Program
11 {
12 delegate string MyDelegate(string msg);
13 static object locker=new object();
14
15 static void Main(string[] args)
16 {
17 WriteLine("Main Thread Begin ,ThreadId is : " + Thread.CurrentThread.ManagedThreadId, ConsoleColor.Green);
18 MyDelegate myDelegate = new MyDelegate(Messgae);
19 //异步调用，传入参数为object类型，此处用stirng示例
20 myDelegate.BeginInvoke("Hello Thread World!", Completed, "传参示例");
21 //模拟线程工作，可以看到两线程同时工作
22 for (int i = 0; i < 5; i++)
23 {
24 Thread.Sleep(1000);
25 WriteLine("Main Thread Works!", ConsoleColor.Green);
26 }
27 WriteLine("Main Thread Complete!", ConsoleColor.Green);
28 Console.ReadKey();
29 }
30
31 static string Messgae(string msg)
32 {
33 WriteLine("Async Thread Begin ,ThreadId is : " + Thread.CurrentThread.ManagedThreadId, ConsoleColor.Red);
34 //模拟线程工作，可以看到两线程同时工作
35 for (int i = 0; i < 5; i++)
36 {
37 Thread.Sleep(500);
38 WriteLine("Async Thread Works!", ConsoleColor.Red);
39 }
40 WriteLine("Async Thread Complete!", ConsoleColor.Red);
41 return msg;
42 }
43
44 static void Completed(IAsyncResult iresult)
45 {
46 //通过 Thread.CurrentThread.ManagedThreadId 可以看出，回调函数运行在异步线程上
47 WriteLine("Async Thread CallBack Begin,ThreadId is : " + Thread.CurrentThread.ManagedThreadId, ConsoleColor.Cyan);
48 AsyncResult result = iresult as AsyncResult;
49 //使用AsyncDelegate获得委托
50 MyDelegate myDelegate = result.AsyncDelegate as MyDelegate;
51 //使用EndInvoke获取返回值
52 string data = myDelegate.EndInvoke(result);
53 //用 AsyncState 获得传入的参数（即19行“传参示例”四个字）
54 string asyncState = result.AsyncState.ToString();
55 WriteLine(data, ConsoleColor.Cyan);
56 WriteLine(asyncState, ConsoleColor.Cyan);
57 //模拟回调函数工作
58 for (int i = 0; i < 3; i++)
59 {
60 Thread.Sleep(500);
61 WriteLine("Async Thread CallBack Works!", ConsoleColor.Cyan);
62 }
63 WriteLine("Async Thread CallBack Complete!", ConsoleColor.Cyan);
64 }
65
66 static void WriteLine(string data, ConsoleColor color)
67 {
68 lock (locker)
69 {
70 Console.ForegroundColor = color;
71 Console.WriteLine(data);
72 Console.ResetColor();
73 }
74 }
75 }
76 }
结果：
时间： 2024-10-09 06:26:12