Я создал небольшую оболочку вокруг CancellationToken
и CancellationTokenSource
. У меня проблема в том, что метод CancelAsync
CancellationHelper
не работает должным образом.
У меня проблема с методом ItShouldThrowAExceptionButStallsInstead
. Чтобы отменить текущую задачу, он вызывает await coordinator.CancelAsync();
, но на самом деле задача не отменяется и не генерирует исключение для task.Wait
.
ItWorksWellAndThrowsException
работает хорошо и использует coordinator.Cancel
, который вообще не является асинхронным методом.
Вопрос, почему задача не отменяется, когда я вызываю метод Cancel CancellationTokenSource
в асинхронном методе?
Не позволяйте waitHandle
сбить вас с толку, это только из-за того, что задание не закончилось раньше.
Пусть код говорит сам за себя:
using System;
using System.Collections.Generic;
using System.Threading;
using System.Threading.Tasks;
namespace TestCancellation
{
class Program
{
static void Main(string[] args)
{
ItWorksWellAndThrowsException();
//ItShouldThrowAExceptionButStallsInstead();
}
private static void ItShouldThrowAExceptionButStallsInstead()
{
Task.Run(async () =>
{
var coordinator = new CancellationHelper();
var waitHandle = new ManualResetEvent(false);
var task = Task.Run(() =>
{
waitHandle.WaitOne();
//this works well though - it throws
//coordinator.ThrowIfCancellationRequested();
}, coordinator.Token);
await coordinator.CancelAsync();
//waitHandle.Set(); -- with or without this it will throw
task.Wait();
}).Wait();
}
private static void ItWorksWellAndThrowsException()
{
Task.Run(() =>
{
var coordinator = new CancellationHelper();
var waitHandle = new ManualResetEvent(false);
var task = Task.Run(() => { waitHandle.WaitOne(); }, coordinator.Token);
coordinator.Cancel();
task.Wait();
}).Wait();
}
}
public class CancellationHelper
{
private CancellationTokenSource cancellationTokenSource;
private readonly List<Task> tasksToAwait;
public CancellationHelper()
{
cancellationTokenSource = new CancellationTokenSource();
tasksToAwait = new List<Task>();
}
public CancellationToken Token
{
get { return cancellationTokenSource.Token; }
}
public void AwaitOnCancellation(Task task)
{
if (task == null) return;
tasksToAwait.Add(task);
}
public void Reset()
{
tasksToAwait.Clear();
cancellationTokenSource = new CancellationTokenSource();
}
public void ThrowIfCancellationRequested()
{
cancellationTokenSource.Token.ThrowIfCancellationRequested();
}
public void Cancel()
{
cancellationTokenSource.Cancel();
Task.WaitAll(tasksToAwait.ToArray());
}
public async Task CancelAsync()
{
cancellationTokenSource.Cancel();
try
{
await Task.WhenAll(tasksToAwait.ToArray());
}
catch (AggregateException ex)
{
ex.Handle(p => p is OperationCanceledException);
}
}
}
}
CancellationHelper.ThrowIfCancellationRequested()
? - person Matthew Watson   schedule 22.06.2015Task.Run
токен актуален только во время создания задачи, при запуске вы должны проверить токен самостоятельно... - person   schedule 22.06.2015CancellationTokenSource.Cancel
, то ееtask.Result
должно бытьTaskStatus.Canceled
, не так ли? - person Balázs Szántó   schedule 22.06.2015task.Status
не будетTaskStatus.Canceled
, даже если вызываетсяCancel
, и я должен проверитьCancellationTokenSource.IsCancellationRequested
- person Balázs Szántó   schedule 22.06.2015TaskStatus.Faulted
, если вы включитеtoken.ThrowIfCancellationRequested()
... - person   schedule 22.06.2015