c# - 如何捕捉 CancellationToken.ThrowIfCancellationRequested

Question

这段代码执行时

cancellationToken.ThrowIfCancellationRequested();

try catch block 不处理异常。

    public EnumerableObservable(IEnumerable<T> enumerable)
    {
        this.enumerable = enumerable;
        this.cancellationSource = new CancellationTokenSource();
        this.cancellationToken = cancellationSource.Token;


        this.workerTask = Task.Factory.StartNew(() =>
        {
            try
            {
                foreach (var value in this.enumerable)
                {
                    //if task cancellation triggers, raise the proper exception
                    //to stop task execution

                    cancellationToken.ThrowIfCancellationRequested();

                    foreach (var observer in observerList)
                    {
                        observer.OnNext(value);
                    }
                }
            }
            catch (AggregateException e)
            {
                Console.Write(e.ToString());                    
            }
        }, this.cancellationToken);

    }

Answer 1

AggregateExceptions在异步操作期间可能出现大量异常时抛出。它们包含所有引发的异常，例如在链接Tasks (通过 . ContinueWith )或级联内 async/await电话。

正如@Mitch Stewart 指出的那样，要处理的正确异常类型是 OperationCancelledException在你的例子中。