Comet风格的API消费带异步/等待

Question

我试图从Comet样式的HTTP中读取，您可以连接到该API，并且它会不断地推送事件。我希望它在启动后在后台运行，但是我的异步/等待是错误的--它冻结了我的UI，我不知道为什么。

private async void button1_Click(object sender, EventArgs e)
{
    await Task.Run((Func<Task>)PushEventReader);
}

public async Task PushEventReader()
{
    var uri = "url.to/api";
    var client = new WebClient();

    client.OpenReadCompleted += async (sender, e) =>
    {
        using (var reader = new StreamReader(e.Result))
        {
            while (!reader.EndOfStream)
            {
                var line = await reader.ReadLineAsync();
                Console.WriteLine(line);
            }
        }
    };
    await client.OpenReadTaskAsync(new Uri(uri));
}

Answer 1

如果您的按钮单击事件只在后台启动作业，那么使用async异步没有意义，等待Task.Run也没有意义，因为之后什么都不做。只需按一下按钮就可以了：

private void button1_Click(object sender, EventArgs e)
{
    Task.Run(async () => await PushEventReader());
}

Task.Run将对传递给它的任何工作排队，以便在ThreadPool上运行，这将有效地使其在后台运行。

Extra:您正在使用的WebClient是一个非托管资源(您可以注意到，由于它实现了IDisposable接口)，在一个using块中使用它们是一个很好的实践，它将为您处理处理：

public async Task PushEventReader()
{
    var uri = "url.to/api";

    using (var client = new WebClient())
    {
        client.OpenReadCompleted += async (sender, e) =>
        {
            using (var reader = new StreamReader(e.Result))
            {
                while (!reader.EndOfStream)
                {
                    var line = await reader.ReadLineAsync();
                    Console.WriteLine(line);
                }
            }
        };

        await client.OpenReadTaskAsync(new Uri(uri));
    }
}