c# blockingcollection怎样实现数据过滤

在C#中，BlockingCollection 是一个线程安全的集合，用于在生产者和消费者之间传递数据。要实现数据过滤，你可以在将数据添加到 BlockingCollection 之前对其进行过滤，或者使用 IEnumerable 接口的 Where 方法进行过滤。

以下是一个简单的示例，展示了如何使用 BlockingCollection 存储整数并在添加之前进行过滤：

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

class Program
{
    static void Main(string[] args)
    {
        // 创建一个线程安全的集合
        BlockingCollection<int> numbers = new BlockingCollection<int>();

        // 创建一个生产者任务，用于向集合中添加数据
        Task producer = Task.Run(() =>
        {
            for (int i = 1; i <= 10; i++)
            {
                // 过滤掉偶数
                if (i % 2 != 0)
                {
                    numbers.Add(i);
                    Console.WriteLine($"Produced: {i}");
                }
            }
            numbers.CompleteAdding();
        });

        // 创建一个消费者任务，用于从集合中获取数据
        Task consumer = Task.Run(() =>
        {
            foreach (var number in numbers.GetConsumingEnumerable())
            {
                Console.WriteLine($"Consumed: {number}");
            }
        });

        // 等待生产者和消费者任务完成
        Task.WaitAll(producer, consumer);
    }
}

在这个示例中，我们创建了一个 BlockingCollection<int> 实例，并启动了一个生产者任务。生产者任务会生成1到10之间的整数，但只将奇数添加到集合中。然后，我们启动了一个消费者任务，它会从集合中获取数据并打印出来。最后，我们等待生产者和消费者任务完成。

请注意，这个示例使用了 Task.Run 来创建生产者和消费者任务，并使用 Task.WaitAll 等待它们完成。在实际应用中，你可能需要根据具体需求调整代码。