如何取消等待中的任务

本文关键字：等待 任务 取消 何取消 | 更新日期: 2023-09-27 18:30:52

我正在玩这些Windows 8 WinRT任务，我正在尝试使用以下方法取消任务，并且它在某种程度上有效。CancelNotification 方法确实被调用，这会让你认为任务已取消，但在后台任务继续运行，然后在完成后，任务的状态始终为已完成且永远不会取消。有没有办法在任务被取消时完全停止任务？

private async void TryTask()
{
    CancellationTokenSource source = new CancellationTokenSource();
    source.Token.Register(CancelNotification);
    source.CancelAfter(TimeSpan.FromSeconds(1));
    var task = Task<int>.Factory.StartNew(() => slowFunc(1, 2), source.Token);
    await task;            
    if (task.IsCompleted)
    {
        MessageDialog md = new MessageDialog(task.Result.ToString());
        await md.ShowAsync();
    }
    else
    {
        MessageDialog md = new MessageDialog("Uncompleted");
        await md.ShowAsync();
    }
}
private int slowFunc(int a, int b)
{
    string someString = string.Empty;
    for (int i = 0; i < 200000; i++)
    {
        someString += "a";
    }
    return a + b;
}
private void CancelNotification()
{
}

如何取消等待中的任务

阅读取消（在 .NET 4.0 中引入，此后基本保持不变）和基于任务的异步模式，后者提供了有关如何将CancellationToken与async方法一起使用的指南。

总而言之，您将CancellationToken传递到支持取消的每个方法中，并且该方法必须定期检查它。

private async Task TryTask()
{
  CancellationTokenSource source = new CancellationTokenSource();
  source.CancelAfter(TimeSpan.FromSeconds(1));
  Task<int> task = Task.Run(() => slowFunc(1, 2, source.Token), source.Token);
  // (A canceled task will raise an exception when awaited).
  await task;
}
private int slowFunc(int a, int b, CancellationToken cancellationToken)
{
  string someString = string.Empty;
  for (int i = 0; i < 200000; i++)
  {
    someString += "a";
    if (i % 1000 == 0)
      cancellationToken.ThrowIfCancellationRequested();
  }
  return a + b;
}
或者

，为了避免修改slowFunc（例如，假设您无法访问源代码）：

var source = new CancellationTokenSource(); //original code
source.Token.Register(CancelNotification); //original code
source.CancelAfter(TimeSpan.FromSeconds(1)); //original code
var completionSource = new TaskCompletionSource<object>(); //New code
source.Token.Register(() => completionSource.TrySetCanceled()); //New code
var task = Task<int>.Factory.StartNew(() => slowFunc(1, 2), source.Token); //original code
//original code: await task;  
await Task.WhenAny(task, completionSource.Task); //New code

您还可以从 https://github.com/StephenCleary/AsyncEx 使用不错的扩展方法，并使其看起来像以下一样简单：

await Task.WhenAny(task, source.Token.AsTask());

尚未涵盖的一种情况是如何在异步方法中处理取消。举一个简单的例子，你需要将一些数据上传到服务，让它计算一些东西，然后返回一些结果。

public async Task<Results> ProcessDataAsync(MyData data)
{
    var client = await GetClientAsync();
    await client.UploadDataAsync(data);
    await client.CalculateAsync();
    return await client.GetResultsAsync();
}

如果要支持取消，最简单的方法是传入令牌并检查它是否已在每个异步方法调用之间取消（或使用 ContinueWith）。如果他们是长时间运行的呼叫，尽管您可能需要等待一段时间才能取消。我创建了一个小的辅助方法，以便在取消后立即失败。

public static class TaskExtensions
{
    public static async Task<T> WaitOrCancel<T>(this Task<T> task, CancellationToken token)
    {
        token.ThrowIfCancellationRequested();
        await Task.WhenAny(task, token.WhenCanceled());
        token.ThrowIfCancellationRequested();
        return await task;
    }
    public static Task WhenCanceled(this CancellationToken cancellationToken)
    {
        var tcs = new TaskCompletionSource<bool>();
        cancellationToken.Register(s => ((TaskCompletionSource<bool>)s).SetResult(true), tcs);
        return tcs.Task;
    }
}

因此，要使用它，只需将.WaitOrCancel(token)添加到任何异步调用中：

public async Task<Results> ProcessDataAsync(MyData data, CancellationToken token)
{
    Client client;
    try
    {
        client = await GetClientAsync().WaitOrCancel(token);
        await client.UploadDataAsync(data).WaitOrCancel(token);
        await client.CalculateAsync().WaitOrCancel(token);
        return await client.GetResultsAsync().WaitOrCancel(token);
    }
    catch (OperationCanceledException)
    {
        if (client != null)
            await client.CancelAsync();
        throw;
    }
}

请注意，这不会停止您正在等待的任务，它将继续运行。您需要使用不同的机制来停止它，例如示例中的 CancelAsync 调用，或者更好的是将相同的CancellationToken传递给Task，以便它最终可以处理取消。不建议尝试中止线程。

我只想补充已经接受的答案。 我被困在这一点上，但我在处理整个事件时走了一条不同的路线。 我没有运行等待，而是将已完成的处理程序添加到任务中。

Comments.AsAsyncAction().Completed += new AsyncActionCompletedHandler(CommentLoadComplete);

事件处理程序如下所示的位置

private void CommentLoadComplete(IAsyncAction sender, AsyncStatus status )
{
    if (status == AsyncStatus.Canceled)
    {
        return;
    }
    CommentsItemsControl.ItemsSource = Comments.Result;
    CommentScrollViewer.ScrollToVerticalOffset(0);
    CommentScrollViewer.Visibility = Visibility.Visible;
    CommentProgressRing.Visibility = Visibility.Collapsed;
}

使用此路由，所有处理都已经为您完成，当任务被取消时，它只会触发事件处理程序，您可以查看它是否在那里被取消。

相关文章：