如何创建已取消的任务

lontivero 发表于 Dev

远处

我正在编写一个Stream类，并在ReadAsync方法中被阻止。请看一下代码，我认为它可以用英语更好地解释情况。

public override Task<int> ReadAsync(byte[] buffer, int offset, int count, System.Threading.CancellationToken cancellationToken)
{
    if (!cancellationToken.IsCancellationRequested)
    {
        return _connection.ReceiveAsync(new ArraySegment<byte>(buffer, offset, count));
    }
    return // <---------------    what here?
}

使用ILSpy，我可以看到其他Stream类返回了一个已取消的任务，如下所示：

return new Task<TResult>(true, default(TResult), TaskCreationOptions.None, cancellationToken);

但是，Task的构造函数是内部的，因此我无法调用它。

Google根本没有帮助我。

迈克·斯特罗贝尔

我知道创建已取消任务的最直接方法是使用TaskCompletionSource：

var tcs = new TaskCompletionSource<int>();
tcs.TrySetCanceled();
return tcs.Task;

如果您以前从未使用过它，请TaskCompletionSource提供一个“承诺式”任务，该任务基本上可以使您说：“在这里，Task立即进行操作，只要我愿意，我都会提供结果（或报告错误/取消）。准备好了。” 当您要自己安排/协调工作时，这很有用，而不是仅仅依赖于TaskScheduler。

另外，如果您使用重写方法async/await，则可以强制取消取消异常自动传播到结果Task：

public async override Task<int> ReadAsync(
    byte[] buffer,
    int offset,
    int count,
    CancellationToken cancellationToken)
{
    cancellationToken.ThrowIfCancellationRequested();

    return await _connection.ReceiveAsync(
        new ArraySegment<byte>(
            buffer,
            offset,
            count));
}

本文收集自互联网，转载请注明来源。

如有侵权，请联系[email protected] 删除。