c# - 以 Thread 或 Task 启动异步方法

Question

我是 C# 的 await/async 的新手，目前正在玩一些东西。

在我的场景中，我有一个简单的客户端对象，它有一个 WebRequest 属性。客户端应通过 WebRequest 的 RequestStream 定期发送事件消息。这是客户端对象的构造函数:

public Client()
{
    _webRequest = WebRequest.Create("some url");
    _webRequest.Method = "POST";

    IsRunning = true;

    // --> how to start the 'async' method (see below)
}

和异步 alive-sender 方法

private async void SendAliveMessageAsync()
{
    const string keepAliveMessage = "{\"message\": {\"type\": \"keepalive\"}}";
    var seconds = 0;
    while (IsRunning)
    {
        if (seconds % 10 == 0)
        {
            await new StreamWriter(_webRequest.GetRequestStream()).WriteLineAsync(keepAliveMessage);
        }

        await Task.Delay(1000);
        seconds++;
    }
}

方法应该如何启动？

new Thread(SendAliveMessageAsync).Start();

或

Task.Run(SendAliveMessageAsync); // changing the returning type to Task

或

await SendAliveMessageAsync(); // fails as of the constructor is not async

我的问题更多是关于我个人对 await/async 的理解，我认为在某些方面可能是错误的。

第三种选择是 throw

The 'await' operator can only be used in a method or lambda marked with the 'async' modifier

Answer 1

How should the method be started?

我投票赞成“以上都不是”。 :)

“即发即弃”是一个很难正确处理的场景。特别是，错误处理总是有问题的。在这种情况下，async void 可能会让您大吃一惊。

如果我不立即await任务，我更愿意显式保存任务:

private async Task SendAliveMessageAsync();

public Task KeepaliveTask { get; private set; }

public Client()
{
  ...
  KeepaliveTask = SendAliveMessageAsync();
}

这至少允许 Client 的使用者检测到 SendAliveMessageAsync 方法抛出的异常并从中恢复。

附带说明一下，这个模式几乎等同于我的 "asynchronous initialization" pattern .