• • 背景：**

通过阅读这么多的源代码，我了解到BlockingCollection<T>的设计是为了摆脱检查线程之间的共享集合中是否有新数据可用的要求。如果有新数据插入到共享集合中，那么您的消费者线程将立即唤醒。因此，您不必在特定的时间间隔内检查消费者线程是否有新数据可用，通常在while循环中。
我也有类似的要求：

• 我有一个大小为1的阻塞集合。
• 此集合将从3个位置（3个生产商）填充。
• 当前使用while循环检查集合是否有内容。
• 想要在阻塞集合得到一个值时立即执行ProcessInbox()方法并清空该集合，而不检查在特定时间间隔内（通常在while循环中）是否有新数据可供消费者线程使用。我们如何实现？

using System;
using System.Collections.Concurrent;
using System.Linq;
using System.Threading;
        
namespace ConsoleApp1
{
     class Program
     {
          private static BlockingCollection<int> _processingNotificationQueue = new(1);

          private static void GetDataFromQueue(CancellationToken cancellationToken)
          {
               Console.WriteLine("GDFQ called");
               int data;
               //while (!cancellationToken.IsCancellationRequested)
               while(!_processingNotificationQueue.IsCompleted)
               {
                    try
                    {
                         if(_processingNotificationQueue.TryTake(out data))
                         {
                              Console.WriteLine("Take");
                              ProcessInbox();
                         }
                    }
                    catch (Exception ex)
                    {

                    }
               }
          }
        
          private static void ProcessInbox()
          {
               Console.WriteLine("PI called");
          }
        
          private static void PostDataToQueue(object state)
          {
               Console.WriteLine("PDTQ called");
               _processingNotificationQueue.TryAdd(1);
          }
        
          private void MessageInsertedToTabale()
          {
               PostDataToQueue(new CancellationToken());
          }
        
          private void FewMessagesareNotProcessed()
          {
               PostDataToQueue(new CancellationToken());
          }
        
          static void Main(string[] args)
          {
               Console.WriteLine("Start");
               new Timer(PostDataToQueue, new CancellationToken(), TimeSpan.Zero,
                   TimeSpan.FromMilliseconds(100));
        
               // new Thread(()=> PostDataToQueue()).Start();
               new Thread(() => GetDataFromQueue(new CancellationToken())).Start();
        
               Console.WriteLine("End");
               Console.ReadKey();
          }
     }
}