可以在CoreCLR上使用'async'修饰符标记入口点吗？

Question

在Stephan Cleary最近关于.NET CoreCLR上的异步控制台应用程序的博客文章中,他向我们展示了在CoreCLR中(目前在Visual Studio 2015上运行,CTP6),入口点"Main"实际上可以标记为async Task,正确编译并实际运行:

public class Program
{
    public async Task Main(string[] args)
    {
        Console.WriteLine("Hello World");
        await Task.Delay(TimeSpan.FromSeconds(1));
        Console.WriteLine("Still here!");
        Console.ReadLine();
    }
}

给出以下输出:

这是由ASP.NET团队的一篇名为"深度潜入"的博客文章强化到ASP.NET 5运行时:

除了静态Program.Main入口点之外,KRE还支持基于实例的入口点.您甚至可以使主入口点异步并返回任务.通过使主入口点成为实例方法,您可以将运行时环境中的服务注入到应用程序中.

我们知道,到目前为止,无法使用'async'修饰符标记入口点.那么,在新的CoreCLR运行时中,这实际上是如何实现的呢？

Answer 1

深入研究 CoreCLR 运行时的源代码，我们可以看到一个名为 的静态类RuntimeBootstrapper，它负责调用我们的入口点：

public static int Execute(string[] args)
{
    // If we're a console host then print exceptions to stderr
    var printExceptionsToStdError = Environment.GetEnvironmentVariable(EnvironmentNames.ConsoleHost) == "1";

    try
    {
        return ExecuteAsync(args).GetAwaiter().GetResult();
    }
    catch (Exception ex)
    {
        if (printExceptionsToStdError)
        {
            PrintErrors(ex);
            return 1;
        }

        throw;
    }
}

我们可以看到，它在内部调用了ExecuteAsync(args).GetAwaiter().GetResult();，这在语义上等同于调用Task.Result，只不过AggregationException我们接收的是未包装的异常，而不是接收到的包装的。

理解这一点很重要，因为关于它是如何发生的并不存在“黑魔法” 。对于当前版本的 CoreCLR 运行时，允许标记该方法，async Task因为它被运行时阻止在调用链的更高处。

附注：

深入研究ExecuteAsync，我们会看到它最终调用：

return bootstrapper.RunAsync(app.RemainingArguments);

当查看内部时MethodInfo，我们看到入口点的实际调用：

public static Task<int> Execute(Assembly assembly, string[] args, IServiceProvider serviceProvider)
{
    object instance;
    MethodInfo entryPoint;

    if (!TryGetEntryPoint(assembly, serviceProvider, out instance, out entryPoint))
    {
        return Task.FromResult(-1);
    }

    object result = null;
    var parameters = entryPoint.GetParameters();

    if (parameters.Length == 0)
    {
        result = entryPoint.Invoke(instance, null);
    }
    else if (parameters.Length == 1)
    {
        result = entryPoint.Invoke(instance, new object[] { args });
    }

    if (result is int)
    {
        return Task.FromResult((int)result);
    }

    if (result is Task<int>)
    {
        return (Task<int>)result;
    }

    if (result is Task)
    {
        return ((Task)result).ContinueWith(t =>
        {
            return 0;
        });
    }

    return Task.FromResult(0);
}