ET介绍——单线程异步

乾寶豐珠寶

单线程异步

前面几个例子都是多线程实现的异步，但是异步显然不仅仅是多线程的。我们在之前的例子中使用了Sleep来实现时间的等待，每一个计时器都需要使用一个线程，会导致线程切换频繁，这个实现效率很低，平常是不会这样做的。一般游戏逻辑中会设计一个单线程的计时器，我们这里做一个简单的实现，用来讲解单线程异步。

1.     // example2_3
2.     class Program
3.     {
4.         private static int loopCount = 0;
6.         private static long time;
7.         private static Action action;
8.         
9.         static void Main(string[] args)
10.         {
11.             Console.WriteLine($"主线程: {Thread.CurrentThread.ManagedThreadId}");
13.             Crontine();
14.             
15.             while (true)
16.             {
17.                 Thread.Sleep(1);
19.                 CheckTimerOut();
20.                
21.                 ++loopCount;
22.                 if (loopCount % 10000 == 0)
23.                 {
24.                     Console.WriteLine($"loop count: {loopCount}");
25.                 }
26.             }
27.         }
28.         
29.         private static void Crontine()
30.         {
31.             WaitTimeAsync(5000, WaitTimeAsyncCallback1);
32.         }
34.         private static void WaitTimeAsyncCallback1()
35.         {
36.             Console.WriteLine($"当前线程: {Thread.CurrentThread.ManagedThreadId}, WaitTimeAsync finsih loopCount的值是: {loopCount}");
37.             WaitTimeAsync(4000, WaitTimeAsyncCallback2);
38.         }
39.         
40.         private static void WaitTimeAsyncCallback2()
41.         {
42.             Console.WriteLine($"当前线程: {Thread.CurrentThread.ManagedThreadId}, WaitTimeAsync finsih loopCount的值是: {loopCount}");
43.             WaitTimeAsync(3000, WaitTimeAsyncCallback3);
44.         }
45.         
46.         private static void WaitTimeAsyncCallback3()
47.         {
48.             Console.WriteLine($"当前线程: {Thread.CurrentThread.ManagedThreadId}, WaitTimeAsync finsih loopCount的值是: {loopCount}");
49.         }
51.         private static void CheckTimerOut()
52.         {
53.             if (time == 0)
54.             {
55.                 return;
56.             }
57.             long nowTicks = DateTime.Now.Ticks / 10000;
58.             if (time > nowTicks)
59.             {
60.                 return;
61.             }
63.             time = 0;
64.             action.Invoke();
65.         }
66.         
67.         private static void WaitTimeAsync(int waitTime, Action a)
68.         {
69.             time = DateTime.Now.Ticks / 10000 + waitTime;
70.             action = a;
71.         }
72.     }

复制代码

 
这个例子同样实现了一个简单的计时方法，WaitTimeAsync调用时会将回调方法跟时间记录下来，主线程每帧都会调用CheckTimerOut，CheckTimerOut里面判断计时器是否过期，过期了则调用回调方法。整个逻辑都在主线程中完成，同样是异步方法。所以异步并非多线程，单线程同样可以异步。上面的例子同样可以改成await的形式。

1.     // example2_3_2
2.     class Program
3.     {
4.         private static int loopCount = 0;
6.         private static long time;
7.         private static TaskCompletionSource<bool> tcs;
8.         
9.         static void Main(string[] args)
10.         {
11.             Console.WriteLine($"主线程: {Thread.CurrentThread.ManagedThreadId}");
13.             Crontine();
14.             
15.             while (true)
16.             {
17.                 Thread.Sleep(1);
19.                 CheckTimerOut();
20.                
21.                 ++loopCount;
22.                 if (loopCount % 10000 == 0)
23.                 {
24.                     Console.WriteLine($"loop count: {loopCount}");
25.                 }
26.             }
27.         }
28.         
29.         private static async void Crontine()
30.         {
31.             await WaitTimeAsync(5000);
32.             Console.WriteLine($"当前线程: {Thread.CurrentThread.ManagedThreadId}, WaitTimeAsync finsih loopCount的值是: {loopCount}");
33.             await WaitTimeAsync(4000);
34.             Console.WriteLine($"当前线程: {Thread.CurrentThread.ManagedThreadId}, WaitTimeAsync finsih loopCount的值是: {loopCount}");
35.             await WaitTimeAsync(3000);
36.             Console.WriteLine($"当前线程: {Thread.CurrentThread.ManagedThreadId}, WaitTimeAsync finsih loopCount的值是: {loopCount}");
37.         }
39.         private static void CheckTimerOut()
40.         {
41.             if (time == 0)
42.             {
43.                 return;
44.             }
45.             long nowTicks = DateTime.Now.Ticks / 10000;
46.             if (time > nowTicks)
47.             {
48.                 return;
49.             }
51.             time = 0;
52.             tcs.SetResult(true);
53.         }
54.         
55.         private static Task WaitTimeAsync(int waitTime)
56.         {
57.             TaskCompletionSource<bool> t = new TaskCompletionSource<bool>();
58.             time = DateTime.Now.Ticks / 10000 + waitTime;
59.             tcs = t;
60.             return t.Task;
61.         }
62.     }

复制代码

 
上面这个例子所有调用全部在主线程中完成，并且使用了await，因此await并不会开启多线程，await具体用没用多线程完全取决于具体的实现
ET开源地址地址：egametang/ET: Unity3D Client And C# Server Framework (github.com)   qq群：474643097

来源:https://www.cnblogs.com/flamesky/archive/2023/05/18/17413679.html
免责声明：由于采集信息均来自互联网，如果侵犯了您的权益，请联系我们【E-Mail:cb@itdo.tech】 我们会及时删除侵权内容，谢谢合作！