c# - 使用 Parallel.Foreach 时的意外行为

Question

我有这个代码:

// positions is a List<Position>
Parallel.ForEach(positions, (position) =>
{
    DeterminePostPieceIsVisited(position, postPieces);
});

private void DeterminePostPieceIsVisited(Position position, IEnumerable<Postpieces> postPieces)
{
    foreach (var postPiece in postPieces)
    {
        if (postPiece.Deliverd)
            continue;

            var distanceToClosestPosition = postPiece.GPS.Distance(position.GPS);

            postPiece.Deliverd = distanceToClosestPosition.HasValue && IsInRadius(distanceToClosestPosition.Value);
        }
    }
}

我知道 50 篇文章必须将属性 Deliverd 设置为 true。但是，在运行这段代码时，我得到了不断变化的结果。有时我得到 44，当我再次运行它时我得到 47。每次执行的结果都不同。

当我使用普通的 foreach 循环运行这段代码时，我得到了预期的结果。所以我知道我对方法 DeterminePostPieceIsVisited 的实现是正确的。

有人可以向我解释为什么每次执行此代码时使用 Parallel foreach 都会给我不同的结果吗？

Answer 1

我认为，您已经尝试避免竞争，但仍然存在竞争 - 如果两个线程同时检查同一个 postPiece，它们可能两者 观察到 Deliverd (sic) 为 false，然后两者都评估它是否已交付到 position(每个线程的不同值) 并且两者都尝试为 Deliverd 设置一个值 - 通常，我猜，其中一个会尝试将其设置为 false。简单修复:

private void DeterminePostPieceIsVisited(Position position, IEnumerable<Postpieces> postPieces)
{
    foreach (var postPiece in postPieces)
    {
        if (postPiece.Deliverd)
            continue;

        var distanceToClosestPosition = postPiece.GPS.Distance(position.GPS);

        var delivered = distanceToClosestPosition.HasValue && IsInRadius(distanceToClosestPosition.Value);
        if(delivered)
            postPiece.Deliverd = true;
    }
}

另外，顺便说一句:

When I run this code using a plain foreach-loop I get the expected result. So I know my implementation of the method DeterminePostPieceIsVisited is correct.

正确的陈述是“我知道我的实现是正确的对于单线程访问”——你没有确定的是该方法对于从多线程调用是安全的。