Как выполнять параллельный параллельный параллельный динамический словарь?

Question

Я пытаюсь порождать потоки в каждом цикле, используя копию значения в dict.

Мое первое понимание было то, что foreach бы создать новую область, и привели к:

Dictionary<string, string> Dict = new Dictionary<string, string>() { { "sr1", "1" }, { "sr2", "2" } }; 
foreach (KeyValuePair<string, string> record in Dict) { 
    new System.Threading.Timer(_ => 
    { 
     Console.WriteLine(record.Value); 
    }, null, TimeSpan.Zero, new TimeSpan(0, 0, 5)); 
} 

, который пишет

1 
2 
2 
2 

вместо (ожидается):

1 
2 
1 
2 

Поэтому я попытался клонировать kvp в foreach:

KeyValuePair<string, string> tmp = new KeyValuePair<string, string>(record.Key, record.Value); 

но это делает тот же результат.

Я также пробовал его с System.Parallel.ForEach, но это кажется необходимым значениям, которые не являются динамическими, что немного напоминает поезд для моего словаря.

Как я могу повторить мой словарь с помощью ниток?

Answer 1

Проблема заключается в том closure over your lambda, способ исправить это, чтобы добавить локальную переменную внутри для цикла

Dictionary<string, string> Dict = new Dictionary<string, string>() { { "sr1", "1" }, { "sr2", "2" } }; 
foreach (KeyValuePair<string, string> record in Dict) { 

    var localRecord = record; 
    new System.Threading.Timer(_ => 
    { 
     Console.WriteLine(localRecord.Value); 
    }, null, TimeSpan.Zero, new TimeSpan(0, 0, 5)); 
} 

Что происходит в вашей версии он захватывает переменную record не значение переменной запись. Поэтому, когда таймер работает во второй раз, он использует «текущее значение» record, который является вторым элементом в массиве.

За кулисами это то, что происходит в вашей версии кода.

public void MainFunc() 
{ 
    Dictionary<string, string> Dict = new Dictionary<string, string>() { { "sr1", "1" }, { "sr2", "2" } }; 
    foreach (KeyValuePair<string, string> record in Dict) { 

     _recordStored = record; 
     new System.Threading.Timer(AnnonFunc, null, TimeSpan.Zero, new TimeSpan(0, 0, 5)); 
    } 
} 

private KeyValuePair<string, string> _recordStored; 

private void AnnonFunc() 
{ 
    Console.WriteLine(_recordStored.Value); 
} 

Посмотрите, как, когда ваша функция побежал в первый itteration имел правильную версию _recordStored, но после того, как _recordStored получил перезаписаны это только покажет последнее установленное значение. Создавая локальную переменную, она не выполняет эту перезапись.

Способ представить это (я не уверен, как я мог бы представить его в примере кода), он создает _recordStored1 первый цикл, _recordStored2 второй цикл и так далее. Функция использует правильную версию _recordStored# для вызова функции.