如何在BlockingCollection上取消GetConsumingEnumerable()

using System;
using System.Collections.Concurrent;
using System.Threading;
using System.Threading.Tasks;

class Program
{
    static void Main()
    {
        BlockingCollection<int> collection = new BlockingCollection<int>();

        // 创建一个CancellationTokenSource用于取消操作
        CancellationTokenSource cancellationTokenSource = new CancellationTokenSource();
        CancellationToken cancellationToken = cancellationTokenSource.Token;

        // 启动一个消费者任务来迭代BlockingCollection
        Task consumerTask = Task.Run(() =>
        {
            try
            {
                foreach (int item in collection.GetConsumingEnumerable(cancellationToken))
                {
                    Console.WriteLine(item);
                }
            }
            catch (OperationCanceledException)
            {
                Console.WriteLine("消费者任务已取消");
            }
        });

        // 添加一些项到BlockingCollection
        for (int i = 0; i < 10; i++)
        {
            collection.Add(i);
        }

        // 取消消费者任务的迭代
        cancellationTokenSource.Cancel();

        // 等待消费者任务完成
        consumerTask.Wait();

        Console.WriteLine("完成");
    }
}