假设我有10个线程忙着做某事他们有时会调用一个方法
public HandleWidgets(Widget w) { HeavyLifting(w) }
但是,我不希望我的10个线程在HeavyLifting(w)上等待,而是将HeavyLifting(w)工作分配给第11个线程,即HeavyLifter线程并以异步方式继续.调度的HeavyLifter线程应该始终是同一个线程,我不想创建多个线程(因此,我不能做这样的事情:C# Asynchronous call without EndInvoke?).
HeavyLifting(w)是“发射并忘记”,因为调用HandleWidgets()的线程不需要回调或类似的东西.
这有什么健康的做法?
解决方法
基本上你有线程是工作的生产者,而一个线程是它的消费者.
创建一个线程并在循环中从BlockingCollection
获取它.这是你的消费者线程,它将调用HeavyLifting.它只会等到一个项目可用,然后处理它:
A call to Take may block until an item is available to be removed.
其他线程可以简单地将项添加到集合中.
请注意,BlockingCollection不保证自行添加/删除项目的顺序:
The order in which an item is removed depends on the type of collection used to create the BlockingCollection instance. When you create a BlockingCollection object,you can specify the type of collection to use