我有一个可量化和可重复的问题，使用任务并行库，BlockingCollection<T>，ConcurrentQueue<T>和GetConsumingEnumerable，同时试图创建一个简单的管道。
简而言之，从一个线程添加条目到默认的BlockingCollection<T>（在后台依赖于ConcurrentQueue<T>），并不能保证它们会从另一个调用GetConsumingEnumerable()方法的线程弹出BlockingCollection<T>。
我已经创建了一个非常简单的Winforms应用程序来复制/模拟它，它只是将整数打印到屏幕上。

• Timer1负责完成工作项目...它使用一个名为_tracker的并发字典，以便知道它已经添加到阻塞集合中的内容。
• Timer2只是记录BlockingCollection和_tracker的计数状态
• START按钮启动一个Paralell.ForEach，它简单地迭代阻塞集合GetConsumingEnumerable()，并开始将它们打印到第二个列表框。
• STOP按钮停止Timer1，防止更多条目添加到阻塞集合中。

public partial class Form1 : Form
{
    private int Counter = 0;
    private BlockingCollection<int> _entries;
    private ConcurrentDictionary<int, int> _tracker;
    private CancellationTokenSource _tokenSource;
    private TaskFactory _factory;

    public Form1()
    {
        _entries = new BlockingCollection<int>();
        _tracker = new ConcurrentDictionary<int, int>();
        _tokenSource = new CancellationTokenSource();
        _factory = new TaskFactory(); 
        InitializeComponent();
    }

    private void timer1_Tick(object sender, EventArgs e)
    { //ADDING TIMER -> LISTBOX 1
        for(var i = 0; i < 3; i++,Counter++)
        {
            if (_tracker.TryAdd(Counter, Counter))
            _entries.Add(Counter);
            listBox1.Items.Add(string.Format("Adding {0}", Counter));
        }
    }

    private void timer2_Tick_1(object sender, EventArgs e)
    { //LOGGING TIMER -> LIST BOX 3
        listBox3.Items.Add(string.Format("Tracker Count : {0} / Entries Count : {1}", _tracker.Count, _entries.Count));
    }

    private void button1_Click(object sender, EventArgs e)
    { //START BUTTON -> LOGS TO LIST BOX 2

        var options = new ParallelOptions {
                                CancellationToken = _tokenSource.Token,
                                MaxDegreeOfParallelism = 1
                            };

        _factory.StartNew(() => { Parallel.ForEach(_entries.GetConsumingEnumerable(), options, DoWork); });

        timer1.Enabled = timer2.Enabled = true;
        timer1.Start();
        timer2.Start();
    }

    private void DoWork(int entry)
    {
        Thread.Sleep(1000); //Sleep for 1 second to simulate work being done.
        Invoke((MethodInvoker)(() => listBox2.Items.Add(string.Format("Processed {0}", entry))));
        int oldEntry;
        _tracker.TryRemove(entry, out oldEntry);
    }

    private void button2_Click(object sender, EventArgs e)
    { //STOP BUTTON
        timer1.Stop();
        timer1.Enabled = false;
    }

以下是事件的顺序：

• 按下开始
• Timer 1 ticks & ListBox 1立即更新3条消息（添加0，1，2）
• ListBox 2随后用3条消息更新，间隔1秒
• 正在处理% 0
• 处理1
• 处理2
• Timer 1 ticks & ListBox 1立即更新3条消息（添加3、4、5）
• ListBox 2有时会更新2条消息，间隔1秒
• 处理3
• 处理4
  *处理中5未打印...似乎已经“失踪”了
• 按下STOP以防止计时器1添加更多消息
• 等等......“处理5”还是没有出现

您可以看到并发字典仍在跟踪1个尚未处理的条目，该条目随后从_tracker中删除
如果我再次按下开始，那么计时器1开始添加更多的3个条目，并行循环回到生活打印5，6，7和8。

我完全不知道为什么会这样。再次调用start显然会调用一个newtask，它会调用一个Paralell foreach，并重新执行GetConsumingEntrance（），它会神奇地找到丢失的条目。我

为什么BlockingCollection.GetConsumingEnumerable()不能保证覆盖添加到集合中的每个项目。
为什么添加更多的条目会导致它“不卡住”并继续处理？