c# – Task.Wait在OperationCanceledException的情况下出现意外行为

CancellationTokenSource cts0 = new CancellationTokenSource(),cts1 = new CancellationTokenSource();
try
{
    var task = Task.Run(() => { throw new OperationCanceledException("123",cts0.Token); },cts1.Token);
    task.Wait();
}
catch (AggregateException ae) { Console.WriteLine(ae.InnerException); }

try { Task.Run(() => { throw new InvalidOperationException("123"); }).Wait(); } // 1
catch (AggregateException ae) { Console.WriteLine(ae.InnerException); }

try { await Task.Run(() => { throw new InvalidOperationException("123"); }); } // 2
catch (InvalidOperationException ex) { Console.WriteLine(ex); }

try { Task.Run(() => { throw new OperationCanceledException("123"); }).Wait(); } // 3 
catch (AggregateException ae) { Console.WriteLine(ae.InnerException); }

try { await Task.Run(() => { throw new OperationCanceledException("123"); }); } // 4
catch (OperationCanceledException ex) { Console.WriteLine(ex); }

这是一个bug. Task.Run在引导下调用任务< Task> .Factory.StartNew.该内部任务正在获得正确的“故障状态”.包装任务不是.

你可以通过调用来解决这个bug

Task.Factory.StartNew(() => { throw new OperationCanceledException("123",cts1.Token,TaskCreationoptions.DenyChildAttach,TaskScheduler.Default);

虽然,您将丢失任务解除的另一个功能.看到：
Task.Run vs Task.Factory.StartNew

更多细节：

这里是Task.Run的代码,您可以看到它正在创建一个包装UnwrapPromise(它来自Task< TResult&gt ;:::

public static Task Run(Func<Task> function,CancellationToken cancellationToken)
{
    // Check arguments
    if (function == null) throw new ArgumentNullException("function");
    Contract.EndContractBlock();

    cancellationToken.ThrowIfSourcedisposed();

    // Short-circuit if we are given a pre-canceled token
    if (cancellationToken.IsCancellationRequested)
        return Task.FromCancellation(cancellationToken);

    // Kick off initial Task,which will call the user-supplied function and yield a Task.
    Task<Task> task1 = Task<Task>.Factory.StartNew(function,cancellationToken,TaskScheduler.Default);

    // Create a promise-style Task to be used as a proxy for the operation
    // Set lookForOce == true so that unwrap logic can be on the lookout for OCEs thrown as faults from task1,to support in-delegate cancellation.
    UnwrapPromise<VoidTaskResult> promise = new UnwrapPromise<VoidTaskResult>(task1,lookForOce: true);

    return promise;
}

它调用的Task构造函数不会取消取消令牌(因此它不知道内部任务的取消令牌).请注意,它会创建一个默认的CancellationToken.这是它所调用的ctor：

internal Task(object state,TaskCreationoptions creationoptions,bool promiseStyle)
{
    Contract.Assert(promiseStyle,"Promise CTOR: promiseStyle was false");

    // Check the creationoptions. We only allow the AttachedToParent option to be specified for promise tasks.
    if ((creationoptions & ~TaskCreationoptions.AttachedToParent) != 0)
    {
        throw new ArgumentOutOfRangeException("creationoptions");
    }

    // m_parent is readonly,and so must be set in the constructor.
    // Only set a parent if AttachedToParent is specified.
    if ((creationoptions & TaskCreationoptions.AttachedToParent) != 0)
        m_parent = Task.InternalCurrent;

    TaskConstructorCore(null,state,default(CancellationToken),creationoptions,InternalTaskOptions.PromiseTask,null);
}

外部任务(UnwrapPromise添加了一个延续).继续检查内部任务.在内部任务发生故障的情况下,它考虑发现一个OperationCanceledException作为指示取消(不管匹配的令牌).以下是UnwrapPromise< TResult> .TrySetFromTask(下面也是调用堆栈,显示它被调用的位置).注意故障状态：

private bool TrySetFromTask(Task task,bool lookForOce)
{
    Contract.Requires(task != null && task.IsCompleted,"TrySetFromTask: Expected task to have completed.");

    bool result = false;
    switch (task.Status)
    {
        case TaskStatus.Canceled:
            result = TrySetCanceled(task.CancellationToken,task.GetCancellationExceptiondispatchInfo());
            break;

        case TaskStatus.Faulted:
            var edis = task.GetExceptiondispatchInfos();
            ExceptiondispatchInfo oceEdi;
            OperationCanceledException oce;
            if (lookForOce && edis.Count > 0 &&
                (oceEdi = edis[0]) != null &&
                (oce = oceEdi.sourceException as OperationCanceledException) != null)
            {
                result = TrySetCanceled(oce.CancellationToken,oceEdi);
            }
            else
            {
                result = TrySetException(edis);
            }
            break;

        case TaskStatus.RanToCompletion:
            var taskTResult = task as Task<TResult>;
            result = TrySetResult(taskTResult != null ? taskTResult.Result : default(TResult));
            break;
    }
    return result;
}

调用堆栈

mscorlib.dll!System.Threading.Tasks.Task<System.Threading.Tasks.VoidTaskResult>.TrySetCanceled(System.Threading.CancellationToken tokenToRecord,object cancellationException) Line 645 C#
    mscorlib.dll!System.Threading.Tasks.UnwrapPromise<System.Threading.Tasks.VoidTaskResult>.TrySetFromTask(System.Threading.Tasks.Task task,bool lookForOce) Line 6988 + 0x9f bytes   C#
    mscorlib.dll!System.Threading.Tasks.UnwrapPromise<System.Threading.Tasks.VoidTaskResult>.ProcessCompletedOuterTask(System.Threading.Tasks.Task task) Line 6956 + 0xe bytes  C#
    mscorlib.dll!System.Threading.Tasks.UnwrapPromise<System.Threading.Tasks.VoidTaskResult>.InvokeCore(System.Threading.Tasks.Task completingTask) Line 6910 + 0x7 bytes   C#
    mscorlib.dll!System.Threading.Tasks.UnwrapPromise<System.Threading.Tasks.VoidTaskResult>.Invoke(System.Threading.Tasks.Task completingTask) Line 6891 + 0x9 bytes   C#
    mscorlib.dll!System.Threading.Tasks.Task.FinishContinuations() Line 3571    C#
    mscorlib.dll!System.Threading.Tasks.Task.FinishStageThree() Line 2323 + 0x7 bytes   C#
    mscorlib.dll!System.Threading.Tasks.Task.FinishStageTwo() Line 2294 + 0x7 bytes C#
    mscorlib.dll!System.Threading.Tasks.Task.Finish(bool bUserDelegateExecuted) Line 2233   C#
    mscorlib.dll!System.Threading.Tasks.Task.ExecuteWithThreadLocal(ref System.Threading.Tasks.Task currentTaskSlot) Line 2785 + 0xc bytes  C#
    mscorlib.dll!System.Threading.Tasks.Task.ExecuteEntry(bool bPreventDoubleExecution) Line 2728   C#
    mscorlib.dll!System.Threading.Tasks.Task.System.Threading.IThreadPoolWorkItem.ExecuteWorkItem() Line 2664 + 0x7 bytes   C#
    mscorlib.dll!System.Threading.ThreadPoolWorkQueue.dispatch() Line 829   C#
    mscorlib.dll!System.Threading._ThreadPoolWaitCallback.PerformWaitCallback() Line 1170 + 0x5 bytes   C#

它注意到OperationCanceledException,并调用TrySetCanceled将任务置于已取消状态.

放在一边

另外需要注意的是,当您开始使用异步方法时,没有一种方法可以使用异步方法注册取消令牌.因此,在异步方法中遇到的任何OperationCancelledException被认为是取消.
看到
Associate a CancellationToken with an async method’s Task