使用.NET ThreadPool.QueueUserWorkItem的匿名代理

Question

我打算发一个问题,但提前想出来并决定发布问题和答案 - 或者至少我的意见.

当使用匿名委托作为WaitCallback时,在foreach循环中调用ThreadPool.QueueUserWorkItem时,似乎将相同的一个foreach-value传递到每个线程.

List< Thing > things = MyDb.GetTheThings();
foreach( Thing t in Things)
{
    localLogger.DebugFormat( "About to queue thing [{0}].", t.Id );
    ThreadPool.QueueUserWorkItem(
        delegate()
        {
            try
            {
                WorkWithOneThing( t );
            }
            finally
            {
                Cleanup();
                localLogger.DebugFormat("Thing [{0}] has been queued and run by the delegate.", t.Id ); 
            }
        });
 }

对于事物中的16个Thing实例的集合,我观察到传递给WorkWithOneThing的每个'Thing'对应于'things'列表中的最后一个项目.

我怀疑这是因为委托正在访问't'外部变量.请注意,我还尝试将Thing作为参数传递给匿名委托,但行为仍然不正确.

当我重新考虑代码以使用命名的WaitCallback方法并将Thing't'传递给方法时,瞧......事物的第一个实例被正确地传递给了WorkWithOneThing.

我想是平行学的一课.我还想象Parallel.For系列解决了这个问题,但是这个库不是我们的选择.

希望这能节省一些时间.

霍华德霍夫曼

Answer 1

这是正确的,并描述了C#如何捕获闭包内的变量.这不是关于并行性的直接问题,而是关于匿名方法和lambda表达式的问题.

这个问题详细讨论了这种语言特征及其含义.