Как отменить задачу в await?

Я'играю с этими задачами Windows 8 WinRT, и я'пытаюсь отменить задачу, используя метод ниже, и это работает до некоторой степени. Метод CancelNotification DOES вызывается, что заставляет вас думать, что задача была отменена, но в фоновом режиме задача продолжает выполняться, а после ее завершения статус задачи всегда остается завершенным и никогда не отменяется. Есть ли способ полностью остановить задачу, когда она отменяется?

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()
{
}
Carlo
Редактировал вопрос 13-го апреля 2012 в 2:41
Программирование
c# task-parallel-library .net-4.5
13-го апреля 2012 в 1:53
31 просмотров
Комментарии к вопросу (1)
Решение

Ознакомьтесь с Cancellation (который был введен в .NET 4.0 и практически не изменился с тех пор) и Task-Based Asynchronous Pattern, который содержит рекомендации по использованию CancellationToken с методами async.

Вкратце, вы передаете CancellationToken в каждый метод, который поддерживает отмену, и этот метод должен периодически проверять его.

private async Task TryTask()
{
  CancellationTokenSource source = new CancellationTokenSource();
  source.CancelAfter(TimeSpan.FromSeconds(1));
  Task 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;
}
Комментарии (22)

Или для того, чтобы избежать модификации slowFunc (например, у вас нет доступа к исходному коду):

var source = new CancellationTokenSource(); //original code
source.Token.Register(CancelNotification); //original code
source.CancelAfter(TimeSpan.FromSeconds(1)); //original code
var completionSource = new TaskCompletionSource(); //New code
source.Token.Register(() => completionSource.TrySetCanceled()); //New code
var task = Task.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());
sonatique
Редактировал ответ 14-го марта 2018 в 6:16
Комментарии (7)

Один случай, который до сих пор'т был покрыт как обработка отмены внутри асинхронного метода. Возьмем для примера простой случай, когда вам нужно, чтобы загрузить некоторые данные в службу заставить его что-то подсчитать и затем вернуть результаты.

public async Task 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 WaitOrCancel(this Task 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();
        cancellationToken.Register(s => ((TaskCompletionSource)s).SetResult(true), tcs);
        return tcs.Task;
    }
}

Поэтому использовать его тогда просто добавьте `.WaitOrCancel(маркер) для любого асинхронного вызова:

public async Task 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;
    }
}

Обратите внимание, что это не остановит задания, вы ждали и она будет продолжать работать. Вы'll необходимо использовать другой механизм, чтобы остановить его, такие как CancelAsync позвонить в Примере, а еще лучше сдать в той жеCancellationTokenкзадача`, так что он может обрабатывать отмену в конце концов. Пытаясь прервать поток разве'т рекомендуется.

kjbartel
Редактировал ответ 6-го августа 2019 в 7:08
Комментарии (4)

Я просто хочу добавить к уже принятому ответу. Я застрял на этом, но я пошел другим путем в обработке завершенного события. Вместо того чтобы запускать await, я добавляю обработчик завершения к задаче.

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;
}

С этим маршрутом вся обработка уже сделана за вас, когда задача отменяется, она просто запускает обработчик события, и вы можете увидеть, была ли она отменена там.

EluciusFTW
Редактировал ответ 19-го декабря 2017 в 4:16
Комментарии (0)