我有如下代码行用于从NetworkStream异步读取：
int bytesRead = await Task<int>.Factory.FromAsync(this.stream.BeginRead, this.stream.EndRead, buffer, 0, buffer.Length, null);
我希望它能够支持取消操作。我看到可以使用CancellationTokenSource来取消任务，但我不知道如何将其传递给TaskFactory.FromAsync()。
是否有可能使通过FromAsync()构造的任务支持取消操作？
编辑：我想要取消一个已经在运行的任务。
很抱歉，FromAsync的语义性质表明，您只是将异步过程适配到TPL的API中（TPL = Microsoft的任务并行库）。
实际上，TPL的ReadAsync控制异步行为本身，而FromAsync仅包装行为（但不控制它）。
由于Cancellation是一个TPL特定的构造，而FromAsync无法控制调用的异步方法的内部工作方式，因此没有一种保证能够干净地取消任务并确保所有资源被正确关闭的方法（这就是为什么它被省略的原因。如果您感兴趣，只需反编译该方法即可）。
在这些情况下，更有意义的做法是自己包装实际的异步调用，并检测OperationCancelled异常，这将为您提供机会通过进行适当的调用来关闭流。
简而言之，答案是否，但没有任何阻止您创建一个通用的重载方法，根据其类型选择正确的策略来干净地关闭流。
FromAsync转换器进行改装。Task引入取消。这不会取消底层操作本身——您的NetworkStream仍将继续从套接字读取所有请求的字节——但它将允许您的应用程序作出反应，就好像操作被取消一样，立即从您的await抛出一个OperationCanceledException（并执行任何已注册的任务继续）。完成后的底层操作结果将被忽略。public static class TaskExtensions
{
public async static Task<TResult> HandleCancellation<TResult>(
this Task<TResult> asyncTask,
CancellationToken cancellationToken)
{
// Create another task that completes as soon as cancellation is requested.
// https://dev59.com/PGMl5IYBdhLWcg3wHj5O#18672893
var tcs = new TaskCompletionSource<TResult>();
cancellationToken.Register(() =>
tcs.TrySetCanceled(), useSynchronizationContext: false);
var cancellationTask = tcs.Task;
// Create a task that completes when either the async operation completes,
// or cancellation is requested.
var readyTask = await Task.WhenAny(asyncTask, cancellationTask);
// In case of cancellation, register a continuation to observe any unhandled
// exceptions from the asynchronous operation (once it completes).
// In .NET 4.0, unobserved task exceptions would terminate the process.
if (readyTask == cancellationTask)
asyncTask.ContinueWith(_ => asyncTask.Exception,
TaskContinuationOptions.OnlyOnFaulted |
TaskContinuationOptions.ExecuteSynchronously);
return await readyTask;
}
}
这是一个使用扩展方法将操作视为在300毫秒后取消的示例：
CancellationTokenSource cts = new CancellationTokenSource();
cts.CancelAfter(TimeSpan.FromMilliseconds(300));
try
{
int bytesRead =
await Task<int>.Factory.FromAsync(this.stream.BeginRead, this.stream.EndRead, buffer, 0, buffer.Length, null)
.HandleCancellation(cts.Token);
}
catch (OperationCanceledException)
{
// Operation took longer than 300ms, and was treated as cancelled.
}
WebClient有一个Cancel方法。要取消未完成的调用，需要关闭Socket或FileStream。NetworkStream.ReadAsync并传递取消令牌可能很诱人，但是Stream.ReadAsync会将令牌丢弃，基本上不被支持。
Stream.ReadAsync只是基类方法。它本身什么也不做。具体的IO操作仅由派生类发出。这些必须本地支持取消。流无法强制执行它们。发生这种情况时，NetworkStream不支持取消。
FromAsync没有重载，支持取消令牌。一个可能的解决方案是添加一层 - 用FromAsync启动自己的操作，然后使用另一个从外部支持取消的Task来读取流，在自定义操作中完成。 - keenthinkerNetworkStream.ReadAsyncзҡ„е……еҲҶзҗҶз”ұпјҹ - avoCancellationToken.Register注册一个回调函数，并从那里调用NetworkStream.Dispose。这应该会取消挂起的读取操作。 - avo