0. 前言
首先立马解释一波为啥会有这样一篇伪标题的 Demo 随笔呢?
不是本人有知识误区，或者要误人子弟
因为大家都知道 emit 写出来的都是同步方法，不可能 await，至少现在这么多年来没有提供对应的功能
这是之前某天在微信群看见讨论怎么 emit 一个异步方法并包装异步结构，简单几句文字也未能清晰的表达
所以趁着元旦节放假有点时间，
简单列举三种我知道方式去达到这样的效果
三种方法都是绕过 emit 直接书写 emit 代码，而是将对应逻辑转到其他方法中，最后 emit 调用方法达到效果
Demo 说明
原始方法是个延迟 2 秒之后返回 55 的方法：
public static async Task<int> GetV() { await Task.Delay(2000); return 55; }
复制代码
现在我们需要把 55 的结果加 6 ，让最终的结果变为 61
我们的测试方法是这样，会输出一些简单的时间，帮助我们了解执行顺序和异步情况
private static async Task Test(MethodInfo method, MethodInfo awaitMehtod) { var caller = CreateCaller(method, awaitMehtod); Console.WriteLine($"Start {awaitMehtod.Name} at: {DateTime.Now}."); var task = caller(); Console.WriteLine($"Call done at: {DateTime.Now}."); var number = await task; Console.WriteLine($"Hello {number} at: {DateTime.Now}."); Console.WriteLine($"End at: {DateTime.Now}."); Console.WriteLine(); }
复制代码
1. ContinueWith
public static Func<Task<int>> CreateCaller(MethodInfo method, MethodInfo awaitMehtod) { var m = new DynamicMethod(Guid.NewGuid().ToString("N"), typeof(Task<int>), Type.EmptyTypes); var il = m.GetILGenerator(); il.Emit(OpCodes.Call, method); il.Emit(OpCodes.Call, typeof(Program).GetMethod(nameof(Program.AddSixUseContinueWith))); // 这里是差异点 il.Emit(OpCodes.Ret);
return m.CreateDelegate(typeof(Func<Task<int>>)) as Func<Task<int>>; }
public static Task<int> AddSixUseContinueWith(Task<int> task) { return task.ContinueWith(i => { Console.WriteLine($"AddSixUseContinueWith is: {DateTime.Now}."); return i.Result + 6; }); }
复制代码
测试结果：
Start AddSixUseContinueWith at: 2021/1/2 13:34:55.Call done at: 2021/1/2 13:34:55.AddSixUseContinueWith is: 2021/1/2 13:34:57.Hello 61 at: 2021/1/2 13:34:57.End at: 2021/1/2 13:34:57.
复制代码
优点
还是真正的异步
缺点
成本比较大，毕竟这样没有了状态机等等优化，（成本在 ns 级别哦，不是大家想的 ms 哦）
2. GetAwaiter().GetResult()
public static Func<Task<int>> CreateCaller(MethodInfo method, MethodInfo awaitMehtod) { var m = new DynamicMethod(Guid.NewGuid().ToString("N"), typeof(Task<int>), Type.EmptyTypes); var il = m.GetILGenerator(); il.Emit(OpCodes.Call, method); il.Emit(OpCodes.Call, typeof(Program).GetMethod(nameof(Program.AddSixUseAwaiter))); // 这里是差异点 il.Emit(OpCodes.Ret);
return m.CreateDelegate(typeof(Func<Task<int>>)) as Func<Task<int>>; }
public static Task<int> AddSixUseAwaiter(Task<int> task) { var r = task.ConfigureAwait(false).GetAwaiter().GetResult() + 6; Console.WriteLine($"AddSixUseAwaiter is: {DateTime.Now}."); return Task.FromResult(r); }
复制代码
测试结果：
Start AddSixUseAwaiter at: 2021/1/2 13:34:57.AddSixUseAwaiter is: 2021/1/2 13:34:59.Call done at: 2021/1/2 13:34:59.Hello 61 at: 2021/1/2 13:34:59.End at: 2021/1/2 13:34:59.
复制代码
优点
执行时间上消耗很小
缺点
当然这样 异步都变成了同步，所以可能会在某些情况下我们操作不当的代码从而导致失去异步方法的优势
3. async/await
public static Func<Task<int>> CreateCaller(MethodInfo method, MethodInfo awaitMehtod) { var m = new DynamicMethod(Guid.NewGuid().ToString("N"), typeof(Task<int>), Type.EmptyTypes); var il = m.GetILGenerator(); il.Emit(OpCodes.Call, method); il.Emit(OpCodes.Call, typeof(Program).GetMethod(nameof(Program.AddSixUseAsyncAwait))); // 这里是差异点 il.Emit(OpCodes.Ret);
return m.CreateDelegate(typeof(Func<Task<int>>)) as Func<Task<int>>; }
public static async Task<int> AddSixUseAsyncAwait(Task<int> task) { var r = await task; Console.WriteLine($"AddSixUseAsyncAwait is: {DateTime.Now}."); return r + 6; }
复制代码
测试结果：
Start AddSixUseAsyncAwait at: 2021/1/2 13:34:59.Call done at: 2021/1/2 13:34:59.AddSixUseAsyncAwait is: 2021/1/2 13:35:01.Hello 61 at: 2021/1/2 13:35:01.End at: 2021/1/2 13:35:01.
复制代码
优点
async / await 本身的优势都没有损失
缺点
原本想在 emit 中 对 result 的处理逻辑 必须迁移到 async / await 方法中，emit 代码必须好好设计
完整 Demo 放在
https://github.com/fs7744/grocery/blob/main/csharp/emit_await/EmitAwaitDemo/Program.cs
分享不易，如果能给予一点动力，不胜感激：关注一下本人的开源项目： Norns.Urd
评论