c# - WriteAsync 超时

Question

我尝试编写一个带有超时的简单异步写入代码，如下所示，并期望该函数在给定非常大的缓冲区和小等待时间的情况下抛出 TaskCanceledException。但是，这不会发生。 WriteAsync 将阻塞数秒，直到写入完成。我错过了什么？

public async void WriteWithTimeout(Stream os, byte[] buf, int waitMs)
{
    CancellationTokenSource tokenSource = new CancellationTokenSource(waitMs); // cancel after waitMs milliseconds.
    await os.WriteAsync(buf, 0, buf.Length, tokenSource.Token);

    return;
}

从 GUI 线程调用:

try
{
    WriteWithTimeout(response.OutputStream, buf100M, w1ms);
}
catch(OperationCanceledException e)
{
    ConsoleWriteLine("Failed with exception: {0}", e.Message);
}        

Answer 1

您无法捕获异步无效。它必须返回一个任务，您必须等待它。

public async Task WriteWithTimeout(Stream os, byte[] buf, int waitMs)
{
    CancellationTokenSource tokenSource = new CancellationTokenSource(waitMs); // cancel after waitMs milliseconds.
    await os.WriteAsync(buf, 0, buf.Length, tokenSource.Token);

    return;
}

界面代码

try
{
    await WriteWithTimeout(response.OutputStream, buf100M, w1ms);
}
catch(OperationCanceledException e)
{
    ConsoleWriteLine("Failed with exception: {0}", e.Message);
}

取消仍然会发生，只是您没有观察到它们。

更新:

有可能 os.WriteAsync( 只是由 Task.Run( 在幕后支持的同步完成¹。取消 token 不会取消已经运行的 Task.Run(。在这种情况下，最好的方法是将取消包装在 Task.WhenAny( 中并传入 token 也通过无限长的 Task.Delay(.

public async Task WriteWithTimeout(Stream os, byte[] buf, int waitMs)
{
    CancellationTokenSource tokenSource = new CancellationTokenSource(waitMs); // cancel after waitMs milliseconds.
    var task = os.WriteAsync(buf, 0, buf.Length, tokenSource.Token);
    var waitedTask = await Task.WhenAny(task, Task.Delay(-1, token));
    await waitedTask; //Wait on the returned task to observe any exceptions.
}

---

^{1。例如，如果您不将 FileOptions.Asynchronous 传递给构造函数}

，则这是 FileStream 的默认行为