用任务并行库实现“only one of”和“not in parallel”语义

也许,我能想到的一个方法是

1. 创建一个包装类-比如说KeyProcessor来为一个键排队。
4. 对于任何新任务,请在字典中查找相同的键。如果不存在,则添加它。对其上的任务进行排队。如果它没有运行,那么使用Run方法作为操作用TPL来调度它。
5. 使用ContinueWith计划维护者任务-例如,每当任务执行时键盘处理器。运行如果已完成,则继续任务可以检查是否为同一个键安排了其他任务(因为它已完成),然后重新启动它或从字典中删除。

System.Collections.Concurrent 命名空间。这将使上述逻辑更加简单。例如, ConcurrentDictionary.GetOrAdd 将允许以线程安全的方式查找和/或添加KeyProcessor对象。

这个问题和我在中解决的问题很相似 ReactiveXaml ,不过我也记下了以前的请求。看一下代码 QueuedAsyncMRUCache blog entry )-此代码将TPL与反应式扩展结合起来,以完成此类操作,但它提供了一个重要的保证,即对同一密钥的第二个请求将在第一个飞行中请求时被阻止,而不是发出另一个请求。