Локальная переменная внутри параллельных петель Безопасность резьбы

Question

У меня есть переменная (cnt) внутри вложенной parallel.foreach. Я запускаю эту программу и, по-видимому, хорошо работает. Кто-нибудь знает, что этот код действительно потокобезопасен? Можно ли определить переменную внутри петель parallel?

спасибо.

object obj = new object(); 
    int total=0; 

    Parallel.For(0, 2, i => 
    { 
     Parallel.For(0, 1000000, j => 
     { 
      int cnt = 0; 
      if ((arr[i, j] % 2) == 0) 
      { 
       Interlocked.Increment(ref cnt); 
      } 
      lock (obj) 
      { 
       total= total+ (cnt/2); 
      } 
     }); 
    }); 

Answer 1

Этот код поточно - только общие данные (total) правильно синхронизированы. Он потокобезопасен даже без использования Interlocked.Increment (то есть: до вашего редактирования).

Однако, это не .

Было бы лучше использовать перегрузку с помощью local initializer and finally delegates.

int total=0; 
Parallel.For(0, 2, 
{ 
    Parallel.For(0, 1000000, 
     local => 0, 
     (j, state, local) => 
      { 
        if ((arr[i, j] % 2) == 0) 
        { 
      ++local; 
        } 
     return local; 
    }, 
     local => Interlocked.Increment(ref total, local) 
    ); 
}); 

Answer 2

Этот код действительно безопасен, поскольку инструкция lock действует как операция полного ограждения. Это гарантирует, что операция приращения атомарна и не будет подвержена гонкам из других потоков