Parallel.ForEach при сохранении порядка

Question

У меня есть List<byte[]>, и мне нравится десериализовать каждого byte[] в Foo. Список упорядочен, и мне нравится писать параллельный цикл, в котором полученный List<Foo> содержит все Foo в том же порядке, что и исходный byte[]. Список значительно большой, чтобы сделать параллельную работу стоящей. Есть ли встроенный способ сделать это?

Если нет, любые идеи о том, как добиться ускорения при запуске всего этого синхронно?

Благодаря

Answer 1

Из информации вы» я понял, вы хотите иметь выходной массив Foo с размером, равным входному массиву байтов? Это верно?

Если да, то операция проста. Не беспокойтесь о блокировке или синхронизированных конструкциях, это приведет к разрушению всей скорости, которую дает вам распараллеливание.

Вместо этого, если вы подчиняются этому простому правилу любой алгоритм может быть распараллелены без блокировки или синхронизации:

Для каждого входного элемента Х [я] обработан, вы можете считывать из любого входного элемента X [J], но только запись в выходной элемент Y [I]

Посмотрите Scatter/Gather, этот тип операции называется собрать как только один выходной элемент записывается.

Если вы можете использовать приведенный выше принцип, тогда вы хотите создать свой выходной массив Foo [] спереди и использовать Parallel.For not ForEach на входном массиве.

Э.Г.

 List<byte[]> inputArray = new List<byte[]>(); 
     int[] outputArray = new int[inputArray.Count]; 

     var waitHandle = new ManualResetEvent(false); 
     int counter = 0; 

     Parallel.For(0, inputArray.Count, index => 
      { 
       // Pass index to for loop, do long running operation 
       // on input items 
       // writing to only a single output item 
       outputArray[index] = DoOperation(inputArray[index]); 

       if(Interlocked.Increment(ref counter) == inputArray.Count -1) 
       { 
        waitHandle.Set(); 
       } 
      }); 

     waitHandler.WaitOne(); 

     // Optional conversion back to list if you wanted this 
     var outputList = outputArray.ToList(); 

Answer 2

Вы можете использовать словарь THREADSAFE с помощью ключа индекса ИНТ для хранения reult от обув так что в конце концов вы будете иметь все в распоряжение заказчика данных в словаре