并行ForEach和队列

5 c# task-parallel-library

是否可以为每个循环处理并行处理队列中的项目,使其:

  1. 仅删除正在处理的项目
  2. 暂停,直到将新项目添加到队列中

编辑:这是关于System.Threading.Tasks的Parallel.ForEach功能

Muh*_*han 8

使用Reactive Extensions订阅队列并执行新任务中的每个项目.您不必阻止或等待新项目,因为它将被推送到您的订阅lambda并且您的执行/处理将是并行的.

http://rxwiki.wikidot.com/101samples