Состояние гонки в Parallel.ForEach?

Question

Возможно ли возможное состояние гонки в нижнем коде?

public void Process(List<SomeObject> list) 
{ 
    SomeDataOutput objData=null; 
    ConcurrentBag<SomeDataOutput> cbOutput = new ConcurrentBag<SomeDataOutput>(); 
    ParallelOptions po = new ParallelOptions(){MaxDegreeOfParallelism=4}; 
    Parallel.ForEach(list, po, (objInput) => 
    { 
     objData = GetOutputData(objInput);//THIS LINE IS THE ONE I AM UNSURE OF. CAN objData GET OVERWRITTEN BY MULTIPLE PARALLEL THREADS? 
     cbOutput.Add(objData); 
    }); 
} 

Answer 1

Да, есть возможное состояние гонки. Два потока может перемежать операторы в теле цикла следующим образом:

Thread #1        Thread #2 
================================== ================================== 
objData = GetOutputData(objInput); 
             objData = GetOutputData(objInput); 
cbOutput.Add(objData); 
             cbOutput.Add(objData); 

Поскольку objData объявлена ​​вне цикла, два потока разделяют ту же переменную. В результате Thread # 2 перезаписывает опорный набор objData по Thread # 1, а Thread # 2 objData добавляется к cbOutput дважды.

Чтобы предотвратить objData от общего доступа нескольких потоков, сделать его локальную переменную:

SomeDataOutput objData = GetOutputData(objInput); 
cbOutput.Add(objData); 

Или вы можете избавиться от этой переменной в целом:

cbOutput.Add(GetOutputData(objInput)); 

Answer 2

Да.

(под редакцию удалить неверную и отвлекающую информацию)

И, как говорит другой ответ, вы можете сделать это: (остальные биты этого ответа предшествуют мои корректировки (спасибо Бен Войт)).

public void Process(List<SomeObject> list) 
{ 
    ConcurrentBag<SomeDataOutput> cbOutput = new ConcurrentBag<SomeDataOutput>(); 
    ParallelOptions po = new ParallelOptions(){MaxDegreeOfParallelism=4}; 
    Parallel.ForEach(list, po, (objInput) => 
    { 
     cbOutput.Add(GetOutputData(objInput)); 
    }); 
} 

И это, очевидно, не имеет риска перезаписать объекты или память.