15.5.3 【Task实现细节】状态机的结构

  状态机的整体结构非常简单。它总是使用显式接口实现,以实现.NET 4.5引入的 IAsync StateMachine 接口,并且只包含该接口声明的两个方法,即 MoveNext 和 SetStateMachine 。

   此外,它还拥有大量私有或公共字段。 状态机的声明在折叠后如代码清单15-11所示:

 1         [CompilerGenerated]
 2         private struct DemoStateMachine : IAsyncStateMachine
 3         {
 4             // Fields for parameters
 5             public IEnumerable<char> text;
 6
 7             // Fields for local variables
 8             public IEnumerator<char> iterator;
 9             public char ch;
10             public int total;
11             public int unicode;
12
13             // Fields for awaiters
14             private TaskAwaiter taskAwaiter;
15             private YieldAwaitable.YieldAwaiter yieldAwaiter;
16
17             // Common infrastructure
18             public int state;
19             public AsyncTaskMethodBuilder<int> builder;
20             private object stack;
21
22             void IAsyncStateMachine.MoveNext()
23         {..............}
24      }

  在这段代码中,我将字段分割为不同的部分。我们已经知道表示原始参数的 text 字段 是由 骨架方法设置的,而 builder 和 state 字段亦是如此,三者皆是所有状态机共享的通用基础设施。

  由于需在多次调用 MoveNext() 方法时保存变量的值,因此每个局部变量也同样拥有着自己 的字段 。有时局部变量只在两个特殊的 await 表达式之间使用,而无须保存在字段中,但就我 的经验来说,当前实现总是会将它们提升为字段。此外,这么做还可以改善调试体验,即使没有 代码再使用它们,也无须担心局部变量丢值了。

   异步方法中使用的 awaiter 如果是值类型,则每个类型都会有一个字段与之对应,而如果是 引用类型(编译时的类型),则所有 awaiter 共享一个字段。本例有两个 await 表达式,分别使 用两个不同的 awaiter 结构类型,因此有两个字段 。如果第二个 await 表达式也使用了一个 TaskAwaiter ,或者如果 TaskAwiater 和 YieldAwiter 都是类,则只会有一个字段。由于一次 只能存活一个 awaiter ,因此即使一次只能存储一个值也没关系。我们需要在多个 await 表达式 之间传播awaiter,这样就可以在操作完成时得到结果。   有关通用的基础设施字段 ,我们已经了解了其中的 state 和 builder 。 state 用于跟踪踪 迹,这样后续操作可回到代码中正确的位置。 builder 具有很多功能,包括创建骨架方法返回的 Task 和 Task<T> ,即异步方法结束时传播的任务,其内包含有正确结果。 stack 字段略微有点晦 涩。当 await 表达式作为语句的一部分出现,并需要跟踪一些额外的状态,而这些状态又没有表 示为普通的局部变量时,才会用到 stack 字段。15.5.6节将介绍一个相关示例,该示例不会用于 代码清单15-11生成的状态机中。

   编译器的所有魔法都体现在 MoveNext() 方法中,但在介绍它之前,我们先来快速浏览一下 SetStateMachine 。在每个状态机中,它都具有完全相同的实现,如下所示:

1             [DebuggerHidden]
2             void IAsyncStateMachine.SetStateMachine(IAsyncStateMachine machine)
3             {
4                 builder.SetStateMachine(machine);
5             }

  简单来说,该方法的作用是:在builder内部,让一个已装箱状态机的复本保留有对自身的引 用。我不想深入介绍如何管理所有的装箱,你只需了解状态机可在必要时得到装箱,同时,异步 机制的各方面可保证在装箱后,还会一直使用这个已装箱的复本。这非常重要,因为我们使用的 是可变值类型(不寒而栗!)。如果允许对状态机的不同复本进行不同的修改,那么整个程序很快 就会崩溃。

  换一个角度来说(如果你开始认真思考状态机的实例变量是如何传播的,这就会变得很重 要),状态机之所以设计为 struct ,就是为了避免早期不必要的堆分配,但大多数代码都将其视 作一个类。围绕 SetStateMachine 的那些引用,让这一切正常运作。

所有代码如下:

  1     class DecompilationSampleDecompiled
  2     {
  3         static void Main()
  4         {
  5             Task<int> task = SumCharactersAsync("test");
  6             Console.WriteLine(task.Result);
  7         }
  8
  9         [DebuggerStepThrough]
 10         [AsyncStateMachine(typeof(DemoStateMachine))]
 11         static Task<int> SumCharactersAsync(IEnumerable<char> text)
 12         {
 13             var machine = new DemoStateMachine();
 14             machine.text = text;
 15             machine.builder = AsyncTaskMethodBuilder<int>.Create();
 16             machine.state = -1;
 17             machine.builder.Start(ref machine);
 18             return machine.builder.Task;
 19         }
 20
 21         [CompilerGenerated]
 22         private struct DemoStateMachine : IAsyncStateMachine
 23         {
 24             // Fields for parameters
 25             public IEnumerable<char> text;
 26
 27             // Fields for local variables
 28             public IEnumerator<char> iterator;
 29             public char ch;
 30             public int total;
 31             public int unicode;
 32
 33             // Fields for awaiters
 34             private TaskAwaiter taskAwaiter;
 35             private YieldAwaitable.YieldAwaiter yieldAwaiter;
 36
 37             // Common infrastructure
 38             public int state;
 39             public AsyncTaskMethodBuilder<int> builder;
 40             private object stack;
 41
 42             void IAsyncStateMachine.MoveNext()
 43             {
 44                 int result = default(int);
 45                 try
 46                 {
 47                     bool doFinallyBodies = true;
 48                     switch (state)
 49                     {
 50                         case -3:
 51                             goto Done;
 52                         case 0:
 53                             goto FirstAwaitContinuation;
 54                         case 1:
 55                             goto SecondAwaitContinuation;
 56                     }
 57                     // Default case - first call (state is -1)
 58                     total = 0;
 59                     iterator = text.GetEnumerator();
 60
 61                 // We really want to jump straight to FirstAwaitRealContinuation, but we can‘t
 62                 // goto a label inside a try block...
 63                 FirstAwaitContinuation:
 64                     // foreach loop
 65                     try
 66                     {
 67                         // for/foreach loops typically have the condition at the end of the generated code.
 68                         // We want to go there *unless* we‘re trying to reach the first continuation.
 69                         if (state != 0)
 70                         {
 71                             goto LoopCondition;
 72                         }
 73                         goto FirstAwaitRealContinuation;
 74                     LoopBody:
 75                         ch = iterator.Current;
 76                         unicode = ch;
 77                         TaskAwaiter localTaskAwaiter = Task.Delay(unicode).GetAwaiter();
 78                         if (localTaskAwaiter.IsCompleted)
 79                         {
 80                             goto FirstAwaitCompletion;
 81                         }
 82                         state = 0;
 83                         taskAwaiter = localTaskAwaiter;
 84                         builder.AwaitUnsafeOnCompleted(ref localTaskAwaiter, ref this);
 85                         doFinallyBodies = false;
 86                         return;
 87                     FirstAwaitRealContinuation:
 88                         localTaskAwaiter = taskAwaiter;
 89                         taskAwaiter = default(TaskAwaiter);
 90                         state = -1;
 91                     FirstAwaitCompletion:
 92                         localTaskAwaiter.GetResult();
 93                         localTaskAwaiter = default(TaskAwaiter);
 94                         total += unicode;
 95                     LoopCondition:
 96                         if (iterator.MoveNext())
 97                         {
 98                             goto LoopBody;
 99                         }
100                     }
101                     finally
102                     {
103                         if (doFinallyBodies && iterator != null)
104                         {
105                             iterator.Dispose();
106                         }
107                     }
108
109                     // After the loop
110                     YieldAwaitable.YieldAwaiter localYieldAwaiter = Task.Yield().GetAwaiter();
111                     if (localYieldAwaiter.IsCompleted)
112                     {
113                         goto SecondAwaitCompletion;
114                     }
115                     state = 1;
116                     yieldAwaiter = localYieldAwaiter;
117                     builder.AwaitUnsafeOnCompleted(ref localYieldAwaiter, ref this);
118                     doFinallyBodies = false;
119                     return;
120
121                 SecondAwaitContinuation:
122                     localYieldAwaiter = yieldAwaiter;
123                     yieldAwaiter = default(YieldAwaitable.YieldAwaiter);
124                     state = -1;
125                     SecondAwaitCompletion:
126                     localYieldAwaiter.GetResult();
127                     localYieldAwaiter = default(YieldAwaitable.YieldAwaiter);
128                     result = total;
129                 }
130                 catch (Exception ex)
131                 {
132                     state = -2;
133                     builder.SetException(ex);
134                     return;
135                 }
136             Done:
137                 state = -2;
138                 builder.SetResult(result);
139             }
140
141             [DebuggerHidden]
142             void IAsyncStateMachine.SetStateMachine(IAsyncStateMachine machine)
143             {
144                 builder.SetStateMachine(machine);
145             }
146         }
147     }

原文地址:https://www.cnblogs.com/kikyoqiang/p/10128147.html

时间: 2024-11-03 17:48:57

15.5.3 【Task实现细节】状态机的结构的相关文章

15.5.6 【Task实现细节】跟踪栈

谈到栈帧(stack frame)时,可能会想到在方法中声明的局部变量.当然,可能还会注意到 一些隐藏的局部变量,如 foreach 循环中的迭代器.但栈上的内容不止这些,至少逻辑上是这样  . 很多情况下,在一些表达式还没有计算出来前,另一些中间表达式是不能使用的.最简单的例子 莫过于加法等二进制操作和方法调用了. 举个极简单的例子,思考下面这一行: var x = y * z; 在基于栈的伪代码中,将为如下形式: push y push z multiply store 现在假设有如下 aw

15.5.2 【Task实现细节】骨架方法的结构

尽管骨架方法中的代码非常简单,但它暗示了状态机的职责.代码清单15-11生成的骨架方 法如下所示: 1 [DebuggerStepThrough] 2 [AsyncStateMachine(typeof(DemoStateMachine))] 3 static Task<int> SumCharactersAsync(IEnumerable<char> text) 4 { 5 var machine = new DemoStateMachine(); 6 machine.text

15.5.1【Task实现细节】 生成的代码

还在吗?我们开始吧.由于深入讲解需上百页的篇幅,因此这里我不会讲得太深.但我会提 供足够的背景知识,以有助于你对整个结构的理解.之后可通过阅读我近些年来撰写的博客文章, 来了解更加错综复杂的细节,或简单地编写一些异步代码并反编译.同样地,这里我只介绍异步 方法,它包含了所有有趣的机制,并且不需要处理异步匿名函数所处的间接层. 说明 警告,勇敢的旅行者—— 前方是实现细节! 本节将描述微软C# 5编译器(随着.NET 4.5的发布而推出)内实现的相关内容.从CTP版到beta版,有些细节变化很大,

css细节复习笔记——结构与层叠

每个合法的文档都会生成一个结构树,有了结构树元素的祖先.属性兄弟元素等等创建选择器来选择元素,这是CSS继承的核心.继承是从一个元素向后代元素传递属性值所采用的机制.面向一个元素使用哪些值时,用户代理不仅要考虑继承,还要考虑特殊性,另外需要考虑声明本身的来源,这个过程就叫层叠. 本文讨论3种机制之间的关联:特殊性.继承和层叠. 特殊性 同一元素可以使用不同的方法来选择元素.但是每个规则,用户代理会计算选择器的特殊性,并将这个特殊性附加到规则的个个声明.如果一个元素有两个或多个冲突的属性声明,那么

.Net4.0如何实现.NET4.5中的Task.Run及Task.Delay方法

前言 .NET4.0下是没有Task.Run及Task.Delay方法的,而.NET4.5已经实现,对于还在使用.NET4.0的同学来说,如何在.NET4.0下实现这两个方法呢? 在.NET4.0下,有一个泛型类,叫TaskCompletionSource<TReuslt>,它能控制Task的行为,如给Task设置结果.设置异常.设置取消等. MSDN是这样描述的(网址): 表示未绑定到委托的 Task<TResult> 的制造者方,并通过Task属性提供对使用者方的访问. 它有以

Task学习

1. 普通任务 普通任务 2. WaitTask 1 static void Main(string[] args) 2 { 3 Console.WriteLine("Main Thread Processing"); 4 waitTaskFinished(); 5 } 6 7 private static void waitTaskFinished() 8 { 9 var task = new Task<int>(CalculateSum); 10 task.Start(

03--(二)编程实践中C语言的一些常见细节

编程实践中C语言的一些常见细节(转载) 对于C语言,不同的编译器采用了不同的实现,并且在不同平台上表现也不同.脱离具体环境探讨C的细节行为是没有意义的,以下是我所使用的环境,大部分内容都经过测试,且所有测试结果基于这个环境获得,为简化起见,省略了异常处理.我不希望读者死记硬背这些细节,而是能在自己的平台上进行实验从而获得对应的结果.另外,本文仅仅关注于C,可能会考虑C++的表现,但在C++和C#环境下的编译器所获得的看似C代码而实不同的结果不作为参考.基础的东西比如“函数参数传值”.“转义字符”

8天玩转并行开发——第二天 Task的使用

在我们了解Task之前,如果我们要使用多核的功能可能就会自己来开线程,然而这种线程模型在.net 4.0之后被一种称为基于 “任务的编程模型”所冲击,因为task会比thread具有更小的性能开销,不过大家肯定会有疑惑,任务和线程到底有什么区别? 1:任务是架构在线程之上的,也就是说任务最终还是要抛给线程去执行. 2:任务跟线程不是一对一的关系,比如开10个任务并不是说会开10个线程,这一点任务有点类似线程池,但是任务相比线程池有很小 的开销和精确的控制. 一:Task 1. 最简单的使用 开启

基础总结篇之三:Activity的task相关

古人學問無遺力,少壯工夫老始成.紙上得來終覺淺,絕知此事要躬行.南宋.陸遊<冬夜讀書示子聿(yù)> 软件行业也是一样,多少前辈不遗余力的奋斗才出现了软件行业的繁荣的景象,其中已有不少成为大师级人物.今天我们站在伟人的肩膀上,自然会有不少的优势,但不要忘了,要在对技术的认知方面有所提升,仍需我们去实践,去实践. 今天我们来讲一下Activity的task相关内容. 上次我们讲到Activity的四种启动模式的时候,已经了解到一些关于task的技术,今天我再向大家介绍一下.task是一个具有栈结