Rx Task.Factory.StartNew 在 .Net 3.5 问题上启动两个任务

Question

我正在 .Net 3.5 上使用反应式扩展库的任务部分，

它工作起来大部分都很顺利，但在一个地方它调用同一任务两次。

通话内容如下：

Task.Factory.StartNew(
    () => Processor.ProcessMessage(incomingMessage),
    TaskCreationOptions.PreferFairness );

有什么想法吗？这是一个错误吗？

---- 更新

我认为问题在于 c# 在 lambda 中执行闭包的方式。 问题不在 TPL 中，同样的问题在普通的旧线程池中返回。

这解决了它：

foreach (var Processor in processors)
{
 object[] crap = new object[2];
 crap[0] = Processor;
 crap[1] = incomingMessage;
 Task.Factory.StartNew(Magic, crap, TaskCreationOptions.PreferFairness);
}

public void Magic(object obj)
{
 object[] crap =(object[]) obj;
 ((IIncomingMessageProcessor)crap[0]).ProcessMessage((IncomingMessageBase)crap[1]);
}

原始来源是：

foreach (var Processor in processors)
{
Task.Factory.StartNew(
    () => Processor.ProcessMessage(incomingMessage),
    TaskCreationOptions.PreferFairness );
}

所以我在处理器周围有闭包，我猜问题是它正在回收相同的对象lambda 和交换处理器

---- 更新 2

我确信这就是问题所在。 我两次创建任务时，都是使用相同的委托（相同的 ObjectID）创建的，并且处理器在迭代之间的目标属性中发生变化。 有人知道有什么好的解决办法吗？

----更新3 这也有效（感谢 Judah Himango）：

foreach (var processor in processors)
{
 var crap = processor;
 Task.Factory.StartNew(() => crap.ProcessMessage(incomingMessage), TaskCreationOptions.PreferFairness);
}

Answer 1

您是否在 lambda 中使用循环变量？例如，

foreach (var foo in blah)
{
   // You're capturing foo inside a lambda -- this probably won't do what you think it will!
   Task.Factory.StartNew(() => foo.Something()); 
}

请参阅为什么不好在 lambda 表达式中使用迭代变量？

2012 年 11 月更新：新的 C# 5 编译器通过更改行为来解决这一混乱领域，以便捕获 foreach 循环变量，即预期的行为。 C# 团队的 Eric Lippert 写入，

我们正在进行重大变革。在 C# 5 中，a 的循环变量
foreach 逻辑上将位于循环内部，因此闭包将
每次关闭变量的新副本。 “for”循环将
不能改变。