草庐IT

GetConsumingEnumerable

全部标签

c# - 为什么迭代 GetConsumingEnumerable() 没有完全清空底层阻塞集合

我有一个使用任务并行库的可量化和可重复的问题,BlockingCollection,ConcurrentQueue&GetConsumingEnumerable在尝试创建一个简单的管道时。简而言之,将条目添加到默认BlockingCollection(在引擎盖下依赖于ConcurrentQueue)来自一个线程,不保证它们会从BlockingCollection中弹出。来自另一个调用GetConsumingEnumerable()的线程方法。我创建了一个非常简单的Winforms应用程序来重现/模拟它,它只将整数打印到屏幕上。Timer1负责排队工作项......它使用一个名为_tra