ToB企服应用市场:ToB评测及商务社交产业平台

标题: .NET6中的await原理浅析 [打印本页]

---

作者: 汕尾海湾    时间: 2023-12-20 21:17
标题: .NET6中的await原理浅析
前言

看过不少关于 await 的原理的文章,也知道背后是编译器给转成了状态机实现的,但是具体是怎么完成的,回调又是如何衔接的,一直都没有搞清楚,这次下定决心把源码自己跑了下,终于豁然开朗了

本文的演示代码基于 VS2022 + .NET 6

示例

1. public class Program
2. {
3.     static int Work()
4.     {
5.         Console.WriteLine("In Task.Run");
6.         return 1;
7.     }
9.     static async Task TestAsync()
10.     {
11.         Console.WriteLine("Before Task.Run");
12.         await Task.Run(Work);
13.         Console.WriteLine("After Task.Run");
14.     }
16.     static void Main()
17.     {
18.         _ = TestAsync();
19.         Console.WriteLine("End");
20.         Console.ReadKey();
21.     }
22. }

复制代码

• 很简单的异步代码,我们来看下,编译器把它变成了啥
  

1. class Program
2. {
3.     static int Work()
4.     {
5.         Console.WriteLine("In Task.Run");
6.         return 1;
7.     }
9.     static Task TestAsync()
10.     {
11.         var stateMachine = new StateMachine()
12.         {
13.             _builder = AsyncTaskMethodBuilder.Create(),
14.             _state = -1
15.         };
16.         stateMachine._builder.Start(ref stateMachine);
17.         return stateMachine._builder.Task;
18.     }
20.     static void Main()
21.     {
22.         _ = TestAsync();
23.         Console.WriteLine("End");
24.         Console.ReadKey();
25.     }
27.     class StateMachine : IAsyncStateMachine
28.     {
29.         public int _state;
30.         public AsyncTaskMethodBuilder _builder;
31.         private TaskAwaiter<int> _awaiter;
33.         void IAsyncStateMachine.MoveNext()
34.         {
35.             int num = _state;
36.             try
37.             {
38.                 TaskAwaiter<int> awaiter;
39.                 if (num != 0)
40.                 {
41.                     Console.WriteLine("Before Task.Run");
42.                     awaiter = Task.Run(Work).GetAwaiter();
43.                     if (!awaiter.IsCompleted)
44.                     {
45.                         _state = 0;
46.                         _awaiter = awaiter;
47.                         StateMachine stateMachine = this;
48.                         _builder.AwaitUnsafeOnCompleted(ref awaiter, ref stateMachine);
49.                         return;
50.                     }
51.                 }
52.                 else
53.                 {
54.                     awaiter = _awaiter;
55.                     _awaiter = default;
56.                     _state = -1;
57.                 }
58.                 awaiter.GetResult();
59.                 Console.WriteLine("After Task.Run");
60.             }
61.             catch (Exception exception)
62.             {
63.                 _state = -2;
64.                 _builder.SetException(exception);
65.                 return;
66.             }
67.             _state = -2;
68.             _builder.SetResult();
69.         }
71.         void IAsyncStateMachine.SetStateMachine(IAsyncStateMachine stateMachine) { }
72.     }
73. }

复制代码

• 编译后的代码经过我的整理,命名简化了,更容易理解
  

状态机实现

• 我们看到实际是生成了一个隐藏的状态机类 StateMachine
  
• 把状态机的初始状态 _state 设置 -1
  
• stateMachine._builder.Start(ref stateMachine); 启动状态机,内部实际调用的就是状态机的 MoveNext 方法
  
• Task.Run 创建一个任务, 把委托放在 Task.m_action 字段,丢到线程池,等待调度
  
• 任务在线程池内被调度完成后,是怎么回到这个状态机继续执行后续代码的呢?
  _builder.AwaitUnsafeOnCompleted(ref awaiter, ref stateMachine); 就是关键了, 跟下去,到了如下的代码:
  1. if (!this.AddTaskContinuation(stateMachineBox, false))
  2. {
  3.     ThreadPool.UnsafeQueueUserWorkItemInternal(stateMachineBox, true);
  4. }
  5. bool AddTaskContinuation(object tc, bool addBeforeOthers)
  6. {
  7.     return !this.IsCompleted && ((this.m_continuationObject == null && Interlocked.CompareExchange(ref this.m_continuationObject, tc, null) == null) || this.AddTaskContinuationComplex(tc, addBeforeOthers));
  8. }

  复制代码
  
  
  • 这里很清楚的看到,尝试把状态机对象(实际是状态机的包装类),赋值到 Task.m_continuationObject, 如果操作失败,则把状态机对象丢进线程池等待调度,这里为什么这么实现,看一下线程池是怎么执行的就清楚了
    
  
  

线程池实现

• .NET6 的线程池实现,实际是放到了 PortableThreadPool, 具体调试步骤我就不放了,直接说结果就是, 线程池线程从任务队列中拿到任务后都执行了 DispatchWorkItem 方法
  

1. static void DispatchWorkItem(object workItem, Thread currentThread)
2. {
3.     Task task = workItem as Task;
4.     if (task != null)
5.     {
6.         task.ExecuteFromThreadPool(currentThread);
7.         return;
8.     }
9.     Unsafe.As<IThreadPoolWorkItem>(workItem).Execute();
10. }
11. virtual void ExecuteFromThreadPool(Thread threadPoolThread)
12. {
13.     this.ExecuteEntryUnsafe(threadPoolThread);
14. }

复制代码

• 我们看到, 线程池队列中的任务都是 object 类型的, 这里进行了类型判断, 如果是 Task , 直接执行 task.ExecuteFromThreadPool, 更有意思的这个方法是个虚方法,后面说明
  
• ExecuteFromThreadPool 继续追下去,我们来到了这里,代码做了简化
  1. private void ExecuteWithThreadLocal(ref Task currentTaskSlot, Thread threadPoolThread = null)
  2. {
  3.     this.InnerInvoke();
  4.     this.Finish(true);
  5. }
  7. virtual void InnerInvoke()
  8. {
  9.     Action action = this.m_action as Action;
  10.     if (action != null)
  11.     {
  12.         action();
  13.         return;
  14.     }
  15. }

  复制代码
• 很明显 this.InnerInvoke 就是执行了最开始 Task.Run(Work) 封装的委托了, 在 m_action 字段
  
• this.Finish(true); 跟下去会发现会调用 FinishStageTwo 设置任务的完成状态,异常等, 继续调用 FinishStageThree 就来了重点: FinishContinuations 这个方法就是衔接后续回调的核心
  1. internal void FinishContinuations()
  2. {
  3.     object obj = Interlocked.Exchange(ref this.m_continuationObject, Task.s_taskCompletionSentinel);
  4.     if (obj != null)
  5.     {
  6.         this.RunContinuations(obj);
  7.     }
  8. }

  复制代码
• 还记得状态机实现么, Task.m_continuationObject 字段实际存储的就是状态机的包装类,这里线程池线程也会判断这个字段有值的话,就直接使用它执行后续代码了
  1. void RunContinuations(object continuationObject)
  2. {
  3.     var asyncStateMachineBox = continuationObject as IAsyncStateMachineBox;
  4.     if (asyncStateMachineBox != null)
  5.     {
  6.         AwaitTaskContinuation.RunOrScheduleAction(asyncStateMachineBox, flag2);
  7.         return;
  8.     }
  9. }
  11. static void RunOrScheduleAction(IAsyncStateMachineBox box, bool allowInlining)
  12. {
  13.     if (allowInlining && AwaitTaskContinuation.IsValidLocationForInlining)
  14.     {
  15.         box.MoveNext();
  16.         return;
  17.     }
  18. }

  复制代码

总结

• Task.Run 创建 Task, 把委托放在 m_action 字段, 把 Task 压入线程池队列,等待调度
  
• _builder.AwaitUnsafeOnCompleted(ref awaiter, ref stateMachine); 尝试把状态机对象放在 Task.m_continuationObject 字段上,等待线程池线程调度完成任务后使用(用来执行后续),若操作失败,直接把状态机对象压入线程池队列,等待调度
  
• 线程池线程调度任务完成后,会判断 Task.m_continuationObject 有值,直接执行它的 MoveNext
  

备注

• 状态机实现中,尝试修改 Task.m_continuationObject,可能会失败,
  就会直接把状态机对象压入线程池, 但是线程池调度,不都是判断是不是 Task 类型么, 其实状态机的包装类是 Task 的子类,哈哈,是不是明白了
  1. class AsyncStateMachineBox<TStateMachine> : Task<TResult>, IAsyncStateMachineBox where TStateMachine : IAsyncStateMachine
  3. static void DispatchWorkItem(object workItem, Thread currentThread)
  4. {
  5.     Task task = workItem as Task;
  6.     if (task != null)
  7.     {
  8.         task.ExecuteFromThreadPool(currentThread);
  9.         return;
  10.     }
  11.     Unsafe.As<IThreadPoolWorkItem>(workItem).Execute();
  12. }

  复制代码

• 还有就是状态机包装类,重写了 Task.ExecuteFromThreadPool,所以线程池调用 task.ExecuteFromThreadPool 就是直接调用了状态机的 MoveNext 了, Soga ^_^
  1. override void ExecuteFromThreadPool(Thread threadPoolThread)
  2. {
  3.     this.MoveNext(threadPoolThread);
  4. }

  复制代码

参考链接

• 关于线程池和异步的更深刻的原理,大家可以参考下面的文章
  

概述 .NET 6 ThreadPool 实现: https://www.cnblogs.com/eventhorizon/p/15316955.html
.NET Task 揭秘（2）：Task 的回调执行与 await: https://www.cnblogs.com/eventhorizon/p/15912383.html

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！

---

欢迎光临 ToB企服应用市场:ToB评测及商务社交产业平台 (https://dis.qidao123.com/)

Powered by Discuz! X3.4