5

我第一次玩异步 CTP大约 15 分钟......（很好）。

这是我拼凑的一个非常简单的服务器：

internal class Server
{
    private HttpListener listener;
    public Server()
    {
        listener = new HttpListener();
        listener.Prefixes.Add("http://*:80/asynctest/");
        listener.Start();
        Go();
    }

    async void Go()
    {
        HttpListenerContext context = await listener.GetContextAsync();
        Go();
        using (var httpListenerResponse = context.Response) 
        using (var outputStream = httpListenerResponse.OutputStream) 
        using (var sw = new StreamWriter(outputStream))
        {
            await sw.WriteAsync("hello world");
        }
    }
}

可以看出，异步方法Go调用自身。在经典的非异步世界中，这会导致堆栈溢出。我认为异步方法不是这种情况，但我想确定，一种或另一种方式。任何人？

4

1 回答 1

13

让我们把它分解成更简单的东西：

async static void Go()
{
    await Something();
    Go();
    await SomethingElse();
}

编译器如何处理这个问题？

基本上这变成了这样的草图：

class HelperClass
{
    private State state = STARTSTATE;
    public void DoIt()
    {

        if (state == STARTSTATE) goto START;
        if (state == AFTERSOMETHINGSTATE) goto AFTERSOMETHING;
        if (state == AFTERSOMETHINGELSESTATE) goto AFTERSOMETHINGELSE;

        START:
        {
           state = AFTERSOMETHINGSTATE;
           var awaiter = Something().MakeAnAwaiter();
           awaiter.WhenDoneDo(DoIt);
           return;
        }

        AFTERSOMETHING:
        {
           Go();
           state = AFTERSOMETHINGELSESTATE;
           var awaiter = SomethingElse().MakeAnAwaiter();
           awaiter.WhenDoneDo(DoIt);
           return;
        }

        AFTERSOMETHINGELSE:

        return;
    }

    static void Go()
    {
        var helper = new HelperClass();
        helper.DoIt();
    }

现在您要记住的是，当每个异步操作完成时，“DoIt”被安排再次被消息循环调用（当然是在适当的助手实例上）。

那么会发生什么？解决它。你第一次打电话给 Go。这使助手成为第一名并调用 DoIt。这调用了Something()，返回一个任务，为该任务创建一个等待者，告诉等待者“当你完成时，调用helper1.DoIt”并返回。

十分之一秒后任务完成，消息循环调用 helper1 的 DoIt。helper1 的状态是 AFTERSOMETHINGSTATE，所以我们使用 goto 并调用 Go。这使得 helper2 并在其上调用 DoIt。这调用了Something()，取回一个任务，为该任务创建一个等待者，告诉等待者“当你完成后，在helper2上调用DoIt”并将控制权返回给helper1的DoIt。这调用了SomethingElse，为该任务创建了一个等待者，并告诉它“当你完成其他事情时，调用helper1的DoIt”。然后它返回。

现在我们有两个任务未完成，堆栈上没有代码。其中一项任务将首先完成。假设SomethingElse 任务首先完成。消息循环调用 helper1.DoIt()，它立即返回。Helper1 现在是垃圾。

稍后，消息循环调用 helper2.DoIt()，并分支到 AFTEROMETHING。现在调用 Go()，它创建了 helper3...

所以不，这里没有无限递归。每次 Go 执行时，它都会异步启动 Something()，然后返回给调用者。在“某事”之后对这些东西的调用发生在以后。“Go”一次只能在堆栈上一次。

于 2011-06-23T03:24:07.153 回答