Parallel.ForEach tout en conservant l'ordre

Question

J'ai un List<byte[]> et j'aime désérialiser chaque byte[] dans Foo. La liste est ordonnée et j'aime écrire une boucle parallèle dans laquelle le résultat List<Foo> contient tous les Foo dans le même ordre que l'original byte[]. La liste est considérablement grande pour rendre l'exploitation parallèle utile. Existe-t-il un moyen intégré d'accomplir cela?

Si ce n'est pas le cas, des idées sur la façon d'accélérer le fonctionnement de tout ceci de manière synchrone?

Merci

Answer 1

De l'information que vous » Vraiment donné, je comprends que vous voulez avoir un tableau de sortie de Foo avec une taille égale au tableau d'entrée d'octets? Est-ce correct?

Si oui, oui l'opération est simple. Ne vous embêtez pas avec des constructions verrouillées ou synchronisées, celles-ci vont éroder toute la vitesse que vous donne la parallélisation.

Au lieu de cela, si vous obéissez cette règle simple tout algorithme peut être parallélisés sans verrouillage ou synchronisation:

Pour chaque élément d'entrée X [i] traitée, vous pouvez lire à partir de tout élément d'entrée X [j], mais seulement écrire à l'élément de sortie Y [i]

Consulter/regroupement, ce type d'opération est appelé un seul Rassemblez élément de sortie est écrite.

Si vous pouvez utiliser le principe ci-dessus, vous voulez créer votre tableau de sortie Foo [] à l'avant, et utiliser Parallel.For ForEach sur le tableau d'entrée.

E.g.

 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

Vous pouvez utiliser un dictionnaire threadsafe avec une clé int index pour stocker le reult de foo donc à la fin, vous aurez tout le donneur d'ordre de données dans le dictionnaire