C# Est-ce qu'une boucle while foreach parallèle est possible?

Question

Je ne sais pas comment fonctionne la gestion des threads internes de Parallel.foreach et si elle peut garantir qu'une telle construction fonctionnerait? Où in.hasNext() attend juste un objet dans le flux d'entrée et renvoie la valeur true.

Parallel.Foreach(Connections, c => 
    { 
     Input in = c.getInput(); 
     while (in.hasNext()) { 
      object o = in.getNext(); 
      dosomething(o); 
     } 
    } 
); 

Fondamentalement, puis-je exécuter un tas de boucles infinies dans une structure foreach parallèle tout en garantissant qu'ils vont tous fonctionner en même temps. (Pour les courageux, puis-je ajuster cela afin que je puisse modifier la liste de connexion en ajoutant (et en supprimant, ce qui devrait être trivial) les connexions et il lira toujours l'entrée de toutes les connexions dans la liste).

Answer 1

1. Le nombre de threads utilisant est limitée, de sorte que certains éléments seront traités les uns après les autres.

2. La modification des listes lors de l'énumération n'est pas bonne. Vous recevrez probablement une exception (en fonction de la liste que vous utilisez

3. Pourquoi ne pas commencer un nouveau fil par connexion

Exemple Code:

public ConnectionOpen(data) 
{ 
    Connection conn=new ... 
    lock(Connections) 
    { 
     Connections.Add(conn); 
    } 

    new Thread(()=> 
    { 
     Receive(conn);//infinite loop goes here 
    }).Start(); 
} 

public ConnectionClose(conn) 
{ 
    bool removed=false; 
    lock(Connections) 
    { 
     removed=Connections.Remove(conn); 
    } 
    if(removed) conn.StopReceiving(); 
} 

Answer 2

Fondamentalement, je peux courir un tas d'infini en boucles dans une structure foreach parallèle tout en garantissant qu'ils fonctionnent tous en même temps

Non seulement un nombre limité de threads de travail seront mis en chantier en même temps, donc si vous exécutez des boucles plus infinies que il y a des discussions, les derniers ne seront jamais courir ...

Answer 3

Techniquement, ce code fonctionnera, mais le nombre exact de threads qui s'exécutent "simultanément" variera

En plus des extensions parallèles, .NET 4 a également ajouté 'hill climbing' et thread injecti sur le pool de threads, donc le pool de threads .NET essaiera d'ajouter des threads à la boucle Parallel.ForEach pour voir si plus de threads sont complétés, puisque le vôtre n'achèvera jamais le nombre de threads variera, mais je suppose que ce sera non -idéal.

Vous pourriez essayer d'utiliser une construction ParallelWhile, l'équipe a écrit un blog à propos de plusieurs façons de le faire, here is one.