c# - キーボードからの ReadsKey タスクが機能しない - コンシューマー/プロデューサー パターン

Question

BlockingCollection を使用して単一のプロデューサー/コンシューマー パターンを実装しています。

キーボードから「c」をクリックすると、CancellationToken を使用して操作をキャンセルしたい。

奇妙なことに、プログラムの実行後にできるだけ早く「c」を押すと、プログラムはイベントをリッスンします。

後で「c」をクリックすると、45000回目の反復でプログラムが反応しなくなります。

プロデューサーにデータを入力する for ループがあります。

        for (int i = 0; i < 50000; i++)
        {
            logger.AddToQueue("Number with flush " + i, true);
        }
        logger.DataItems.CompleteAdding();

ロガーのコンストラクターで、このメソッドを呼び出します。

    private Task t;
    public void KeyPress()
    {

       t = Task.Run(() =>
            {
                if (Console.ReadKey(true).KeyChar == 'c')
                {
                        cts.Cancel();
                }
            });
    }

エラーが他の方法に関連しているかどうかはわかりませんが、念のため投稿します。

addToQueue (プロデューサー):

    public void AddToQueue(String text, bool isFlushOn) {
         Consumer(isFlushOn);
            try {
                 _dataItems.TryAdd(new LogLine() { Text = text, Timestamp = DateTime.Now }, 0, ct);
            } catch (OperationCanceledException) {
                _dataItems.CompleteAdding();
            }
    }

そして消費者：

    Task task = null;
    public void Consumer(bool isStopWithFlushOn)
    {

        if (task == null)
        {
            task = Task.Run(() =>
            {
                while (!_dataItems.IsCompleted) {
                    try {
                        LogLine data = null;
                        if (!_dataItems.TryTake(out data, 5, ct)) {
                            Console.WriteLine(" Take Blocked");
                        } else {
                            StringBuilder stringBuilder = new StringBuilder();
                            stringBuilder.Append(data.Timestamp.ToString("yyyy-MM-dd HH:mm:ss:fff"));
                            stringBuilder.Append("\t");
                            stringBuilder.Append(data.LineText());
                            stringBuilder.Append("\t");
                            _writer.WriteLine(stringBuilder.ToString());
                            Console.WriteLine(" Take:{0}", data.Text);
                        }
                    } catch (OperationCanceledException) {
                        if (isStopWithFlushOn) {
                            Console.WriteLine("Canceled with flush.");
                            foreach (var dataItem in _dataItems.GetConsumingEnumerable()) {
                                Console.WriteLine("Canceled Take:{0}", dataItem.Text);
                                StringBuilder stringBuilder = new StringBuilder();

                                stringBuilder.Append(dataItem.Timestamp.ToString("yyyy-MM-dd HH:mm:ss:fff"));
                                stringBuilder.Append("\t");
                                stringBuilder.Append("Number with flush " + dataItem.LineText());
                                stringBuilder.Append("\t");
                                _writer.WriteLine(stringBuilder.ToString());
                                Thread.SpinWait(500000);
                            }
                        } else {
                            Console.WriteLine("Canceled without flush.");
                            break;
                        }
                    }

                }
                Console.WriteLine("\r\nNo more items to take.");
            });
        }
    }