c# - CancellationTokenBlockingCollectionから抜け出さないキャンセル

Question

私はそのようなキャンセルトークンを持っています

   static CancellationTokenSource TokenSource= new CancellationTokenSource();

私はそのようなブロッキングコレクションを持っています

BlockingCollection<object> items= new BlockingCollection<object>();

var item = items.Take(TokenSource.Token);

if(TokenSource.CancelPending)
   return;

電話すると

TokenSource.Cancel();

テイクは本来のように続行されません。ポーリングでTryTakeを使用すると、トークンはキャンセル済みとして設定されていることを示します。

Answer 1

それは期待どおりに機能しています。操作をキャンセルすると、items.TakeがスローされOperationCanceledExceptionます。このコードはそれを示しています：

static void DoIt()
{
    BlockingCollection<int> items = new BlockingCollection<int>();
    CancellationTokenSource src = new CancellationTokenSource();
    ThreadPool.QueueUserWorkItem((s) =>
        {
            Console.WriteLine("Thread started. Waiting for item or cancel.");
            try
            {
                var x = items.Take(src.Token);
                Console.WriteLine("Take operation successful.");
            }
            catch (OperationCanceledException)
            {
                Console.WriteLine("Take operation was canceled. IsCancellationRequested={0}", src.IsCancellationRequested);
            }
        });
    Console.WriteLine("Press ENTER to cancel wait.");
    Console.ReadLine();
    src.Cancel(false);
    Console.WriteLine("Cancel sent. Press Enter when done.");
    Console.ReadLine();
}