在 Parallel.For 中修改方法局部变量。这有多线程安全？

Question

我有这个代码sn-p：

int totalData = result.Data.Count;
int count = 0;
Parallel.ForEach(result.Data, data =>
{
    try
    {
        EventRange importedEntity = ImportEntity(auxResult.EntityName, data);
        count++;
        EntityImported(importedEntity, count, totalData);
    }
    catch (Exception e)
    {
        exceptions.Enqueue(e);
    }
});

EntityImported 是一个事件，它应该说明已经处理了多少实体，以及我应该处理多少实体。我担心在 lambda 中递增计数的线程安全性，以及您建议采取哪些步骤来确保始终使用正确的计数变量值触发事件。

Answer 1

目前它根本不是线程安全的。

您可以改用Interlocked.Increment(ref count)，但通常最好为每个线程设置一个“本地”值，并在最后对它们求和。这样，除了分配要处理的项目之外，您不需要任何类型的跨线程数据流。

Parallel.ForEach 的重载就是为此目的而设计的 - 请查看文档底部附近的示例，因为它正在执行与您的代码非常相似的操作非常。 （它维护一个本地计数，然后在最后对计数求和。）不幸的是，由于您需要在每次迭代中引发事件的方式，这对您的特定情况没有帮助 - 但 通常这是一个更好的方法。

在这种情况下，您应该在事件引发代码中使用Interlocked.Increment 的结果：

Parallel.ForEach(result.Data, data =>
{
    try
    {
        EventRange importedEntity = ImportEntity(auxResult.EntityName, data);
        int newCount = Interlocked.Increment(ref count);
        EntityImported(importedEntity, newCount, totalData);
    }
    catch (Exception e)
    {
        exceptions.Enqueue(e);
    }
});

这样一来，每次计数都会引发一个事件（因此一个为 0，一个为 1，一个为 2，等等）。