Langage C#
  1. Langage C#
  3. boucle foreach parallèle – comportement étrange
Intereting Posts
impression double avec chiffres après le point décimal C # accédant au membre protégé dans la classe dérivée Clone de la classe dérivée de la méthode de la classe de base Aide Linq – La trace SQL renvoie le résultat, mais datacontext renvoie null Comment implémenter correctement la référence d’une autre entité à l’utilisateur d’identité? “Court-circuiter” les méthodes vides avec Moq? Comment convertir des données HEX en datetime Pourquoi mon service .NET démarre-t-il vraiment au démarrage XP? Boîte de dialog multiple LUIS / Bot Framework, déplacement de la gestion de l’intention dans une autre boîte de dialog Pourquoi C # Array.BinarySearch est-il si rapide? Python peut-il recevoir un tableau de chaînes de longueur variable de C #? Référence d’object non définie sur un object (appel du modèle Razor à partir de View) Comment append du texte au Presse-papiers dans Windows Phone Runtime? Pouvons-nous accéder à l’API GMAIL à l’aide d’un compte de service? HttpRequest et POST

boucle foreach parallèle – comportement étrange

Le code ci-dessous crée simplement une liste> de nombres aléatoires, puis calcule la sum cumulée de chaque liste dans une boucle foreach parallèle. Pourquoi ai-je moins d’évaluations que ‘numLists’? Souvent autour de 9990. Je suppose que cela a quelque chose à voir avec la sécurité du fil. Quelle est une méthode alternative? (Je suis un débutant en C #, alors j’espère que j’utilise les termes corrects) Merci. 

using System; using System.Collections.Generic; using System.Threading.Tasks; namespace testParallelForeach { class Program { static void Main(ssortingng[] args) { List<List> bsData = new List<List>(); List<List> cumsumDataP = new List<List>(); int numLists = 10000; int myLen = 400; Random rand = new Random(); for (int i = 0; i < numLists; i++) { bsData.Add(new List()); for (int j = 0; j  cumsumDataP.Add(CumulativeSumParallel(a))); Console.WriteLine("cumsumDataP.Count={0}", cumsumDataP.Count); Console.ReadKey(); } public static List CumulativeSumParallel(List singleRetSeries) { int r = singleRetSeries.Count; List cumsumList = new List(); cumsumList.Add(singleRetSeries[0]); for (int i = 1; i < r; i++) { cumsumList.Add(cumsumList[i - 1] + singleRetSeries[i]); } return cumsumList; } } }

List n’est en effet pas thread-safe, donc cumsupDataP.Add(...) supprime des données de manière imprévisible.

Remplacez cette ligne par: 

 ConcurrentBag> cumsumDataP = new ConcurrentBag>();

et tout fonctionnera. Notez que ConcurrentBag n’est pas ordonné , mais c’est acceptable car vous n’avez aucun moyen de prédire l’ordre à partir des threads de toute façon;