予期しない動作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個のポスト片がtrueにプロパティDeliverdセットを持たなければならないことを知っています。しかし、このコードを実行すると、結果が変化します。時々私は44になり、別の時間に実行すると47になります。結果は実行ごとに異なります。

普通のforeachループを使用してこのコードを実行すると、予想される結果が得られます。だから私はDeterminePostPieceIsVisitedメソッドの実装が正しいことを知っています。

誰かが私にこのコードを実行するたびに異なる結果を与えるParallel foreachを使用する理由を説明できますか？同じコレクションが複数のスレッドによって変更されるよう、原因のデータが破損する結果に差が生じる競合状態を引き起こしている、次の並列コードで

Answer 1

：私はそれはのように動作させるために考えることができます

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

簡単な方法今のコードのlockこの作品です：

public static readonly Object lockObj = new Object(); 

lock(lockObj) 
{ 
    postPiece.Deliverd = distanceToClosestPosition.HasValue && IsInRadius(distanceToClosestPosition.Value); 

} 

は、私はより良いデザインを用意している場合、ここでの課題は、すべてのスレッドがコレクションに同時に上で作業してオブジェクト

012を更新している、私は考えてみましょう

IEnumerable<Postpieces> postPieces 

理想的には、すべてのスレッドは、データ破損や競合状態を回避するために、独自のデータセットで作業する必要があります。これは予期しない動作でもありません。あなたはすでに、私が思うに、レースを避けるためにしようとしましたが、一つはまだある

Answer 2

- 2つのスレッドが同時に同じpostPieceを検討しているならば、彼らは両方はDeliverd（原文のまま）がfalseであることを観察することができますそれから、position（各スレッドの個別の値）に配信されているかどうかを評価し、両方ともDeliverdの値を設定しようとします。しばしば、そのうちの1つが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; 
    } 
} 

また、方法によって：

私は無地のforeachループを使用してこのコードを実行すると、私は期待される結果を得ます。だから私はDeterminePostPieceIsVisitedメソッドの実装が正しいことを知っています。

状態に正しいものは次のようになりますです「私は私の実装では、シングルスレッドのアクセスため正しいことを知っている」 - 何が確立していなかったことは方法は、複数のスレッドから呼び出すために安全だったということです。

Answer 3

ConcurrentBag<T>で問題を解決しました。ここで私が今使っていることは次のとおりです：

var concurrentPostPiecesList = new ConcurrentBag<Postpiece>(postPieces); 
Parallel.ForEach(positions, (position) => 
{ 
    DeterminePostPieceIsVisited(position, concurrentPostPiecesList); 
}); 

private void DeterminePostPieceIsVisited(Position position, ConcurrentBag<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); 
    } 
}