Discussion :

[Exo]

Hello tous le monde,

Je bloque au niveau des threads.

D'apres un fichier avec des logs, j'aimerais lancé X fois un pogramme.

Je lis donc mon fichier et pour chaque ligne le lance ma fonction Log.

StreamReader reader = new StreamReader(FILE);
string line = reader.ReadLine();
int count = 0;
int i=0;
while (line != null)
{
Console.WriteLine(line);
Log(line);
line = reader.ReadLine();
count++;
i++;
}
reader.Close( );

Est il possible de lancer par example 6 fois ceci?
Merci de votre aide

[cinemania]

Il est tout a fait possible de lancer plusieurs fois le meme traitement de facon parallele...
Mais avant tout il y a des notions et des contraintes à respecter si tu ne tient pas a avoir des problemes assez gênants.

Je ne sais pas quel est ton niveau en terme de synchronisation de processus ou threads.
Quoi qu'il en soit voici quelques règles à respecter sinon ba les exceptions vont fuser, et les boucles infinies aussi :

- Les fichiers:
Lorsqu'un fichier est ouvert en lecture, selon le partage, il est ou pas possible de l'ouvrir en lecture depuis un autre process (partagé ou exclusif), mais il est IMPOSSIBLE de l'ouvrire en écriture depuis un autre processus.
Lorsqu'un fichier est ouvert en écriture, il n'y a pas de partage. Il est obligatoirement ouvert en mode EXCLUSIF, ce qui signifie qu'aucun autre processus ne peut l'ouvrir dans quelque mode que ce soit.
Attention: L'ouverture d'un fichier déjà ouvert par un autre processus, ne bloque pas le thread en cours, mais lève une exception...
- Il ne faut SURTOUT PAS utiliser d'"Attente Active" pour endormir un thread en attendant un résultat ou une ressource.

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

while (ressource != libre) {}

l'attente active va provoquer des ralentissements et des lenteurs inutiles, sur tous les autres thread du processus. Il faut endormir le thread autrement (en utilisant des synchronisation comme lock (m_Locker) { ton code une fois la ressource libre } qui endorment EFFECTIVEMENT un thread dans l'ordonnanceur.
Donc une boucle du style

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
9
 
bool ok = false;
StreamReader reader = null;
while (!ok) 
try {
  reader = new StreamReader(FILE);
ok = true;
} catch { ok = false; }
/// le reste de ton code une fois le fichier réellement ouvert

est à BANNIR !

Je te conseil de lire le fichier d'abord, de tout stocker en mémoire dans une file.
puis de synchroniser les threads sur leur accès à la file (pour y lire une ou un lot de valeurs)

Si toutefois chaque thread lit et traite un fichier séparé, cela ne pose pas de problème dans la synchronisation, et ton code peut etre utilisé comme corps de chaque threads.

Compte tenu du fait que tu souhaite allouer entre 5 et 6 threads, je te suggère d'utiliser les threads de la pool pour exécuter ces opérations, plutot que les créer toi meme.
Le fait d'utiliser les threads de la pool est plus rapide car ceux si sont déjà créés et initialisés, ils attendent juste qu'on leur confie un job.
System.Threading.ThreadPool est ton ami

[Exo]

Super merci, je regardais justement dans cette voix!