Accueil > Forum > > > > Problème multithread
Problème multithread
mardi 25 juillet 2006 à 17:36:43 |
Problème multithread

froggyinfo
|
Bonsoir,
Voila j'ai un problème avec un programme multi-thread,
J'ai raccourci un peu le code est remplacé les fonctions par des recup1 à 4.
Le but du programme :
Le programme doit en fait consulter une base de donnée pour avoir une liste alerte.
Ensuite un certain nombre de thread vont aller taper dans le résultat de l'alerte. j'utilise alors la classe mutex pour qu'un seul thread puisse accéder à une alerte. Une fois les informations récupérés ce thread lance lui 4 thread.
Et c'est la que j'ai l'impression que la gestion n'est pas bonne.
Alors soit tout est ok et pour vous il n'y a pas de problèmes. Ou soit ya un problème et dans ce cas, je veux bien un petit coup de pouce.
using System; using System.Collections; using System.Collections.Generic; using System.Text; using System.Threading;
using System.Data.SqlClient; using System.Data; using System.Reflection;
class Program { private static Mutex mut = new Mutex(); private static int nbThread = 3; private static bool terminer = false; private const string sqlConnexionStr = "chaine de connexion à la base"; protected SqlDataReader cible; private int i = 0; static void Main() { Program p = new Program(); p.lanceThread(); Console.ReadLine(); }
public void lanceThread() { SqlCommand recupCible = new SqlCommand(); SqlConnection conn = new SqlConnection(sqlConnexionStr); recupCible.Connection = conn; conn.Open(); try { recupCible.CommandType = System.Data.CommandType.StoredProcedure; recupCible.CommandText = "recupCible"; recupCible.CommandTimeout = 3600; cible = recupCible.ExecuteReader(); } catch (Exception e) { Console.WriteLine(e.Message); } finally { // conn.Close(); }
for (int i = 0; i < nbThread; i++) { Thread th = new Thread(new ThreadStart(RecupEnvoiMail)); th.Name = i.ToString(); th.Start(); } }
public void RecupEnvoiMail() { VarFoncMail v = new VarFoncMail(); bool read = false; while(!terminer) { mut.WaitOne(); Console.WriteLine("entré"); Console.WriteLine("Thread" + Thread.CurrentThread.Name); try { read = false; if (!terminer) { if (!cible.Read()) { terminer = true; } else { i++; Console.WriteLine("-------->>>>>>" + i.ToString()); v = new VarFoncMail( System.Convert.ToInt32(cible["idalerte"])); read = true; } } } catch (Exception e) { Console.WriteLine(e.Message); terminer = true; } finally { Console.WriteLine("Sortie"); mut.ReleaseMutex(); } if (read) { try { Thread t = new Thread(new ThreadStart(v.recup1)); t.Name = "thread1_" + Thread.CurrentThread.Name; t.IsBackground = true; Thread t2 = new Thread(new ThreadStart(v.recup2)); t2.Name = "thread2_" + Thread.CurrentThread.Name; t2.IsBackground = true; Thread t3 = new Thread(new ThreadStart(v.recup3)); t3.Name = "thread3_" + Thread.CurrentThread.Name; t3.IsBackground = true; Thread t4 = new Thread(new ThreadStart(v.recup4)); t4.Name = "thread4_" + Thread.CurrentThread.Name; t4.IsBackground = true; t.Start(); t2.Start(); t3.Start(); t4.Start(); t.Join(); t2.Join(); t3.Join(); t4.Join(); try { // execution de code } catch (Exception e) { Console.WriteLine(e.Message); } //Insertion des informations en base Console.WriteLine("fin thread" + Thread.CurrentThread.Name); } catch (Exception) { Console.WriteLine("erreur : "); } } } } }
class VarFoncMail { //info pour alerte public int idalerte; public static Random r = new Random(unchecked((int)(DateTime.Now.Ticks)));
public VarFoncMail() { } public VarFoncMail(int pidalerte) { this.idalerte = pidalerte; }
public void recup1() { int t = r.Next(1, 10) * 1000; Thread.Sleep(t); Console.WriteLine(Thread.CurrentThread.Name + " " + idalerte + "-----" + t); }
public void recup2() { int t = r.Next(1, 10) * 1000; Thread.Sleep(t); Console.WriteLine(Thread.CurrentThread.Name + " " + idalerte + "-----" + t);
}
public void recup3() { int t = r.Next(1, 10) * 1000; Thread.Sleep(t); Console.WriteLine(Thread.CurrentThread.Name + " " + idalerte + "-----" + t); }
public void recup4() { int t = r.Next(1, 10) * 1000; Thread.Sleep(t); Console.WriteLine(Thread.CurrentThread.Name + " " + idalerte + "-----" + t); } }
Merci beacoup
Froggyinfo
|
|
mercredi 26 juillet 2006 à 08:37:10 |
Re : Problème multithread

crougni
|
Salut, pourquoi exactement tu suppose que ton prog fonctionne pas ? tu as constaté un problème précis ou pas vraiement ? perso, je vois un truc, qui pourrait faire que sa croucroute, c'est que tes threads RecupEnvoiMail peuvent modifier ta vairable Read chacun leurs tour sans pour autant avoir lancé les 4 sous-threads. Cad que les Thread 0 [RecupEnvoiMail] , lit la première alerte, positionne Read à Vrai, puis le Thread 1 [RecupEnvoiMail], fait pareil, mais n'arrive pas à lire, car par exemple il n'y a plus d'alerte, et du coup positionne Read à faux, alors que ton thread 0 à pas encore lancé ses sous-thread. Donc moi je n'utiliserai pas du tout ta variable Read, elle sert à rien, et je lancerai mes sous-thread juste après la lecture. de plus de remplacerai ton mutex par un bon lock(this) genre : ... while(!terminer) { lock(this) { Console.WriteLine("entré"); Console.WriteLine("Thread" + Thread.CurrentThread.Name); try { ...
Voila, mais si tu pouvais juste décrire le soucis que tu constate.... A+ 
|
|
mercredi 26 juillet 2006 à 10:34:06 |
Re : Problème multithread

froggyinfo
|
En fait ce qu'il se passe c'est que j'ai l'impression que les thread ne s'exécutent pas en parallèle mais l'un après l'autre.
Et je ne comprend pas pourquoi ?
Greg
|
|
mercredi 26 juillet 2006 à 10:37:24 |
Re : Problème multithread

froggyinfo
|
De plus à propos du read, il est propre à chaque thread et non commun à tous les threads. Je ne comprend pas pourquoi ca viendrait de ma variable read.
Greg
|
|
mercredi 26 juillet 2006 à 15:58:06 |
Re : Problème multithread

froggyinfo
|
Personne n'a un site à me conseiller pour les thread ?
|
|
mercredi 26 juillet 2006 à 23:49:52 |
Re : Problème multithread

Bidou
|
Salut, J'ai simplifié ton code en supprimant tout ce qui était en rapport avec la base donnée. Et apparement y'a pas de problème, tout semble s'exécuter correctement "en parallèle". Comment peux-tu affirmer que ce n'est pas le cas. Ou alors y'a un prob avec la database (je ne peux pas tester ça pour l'instant...)
VC# forever 
|
|
jeudi 27 juillet 2006 à 10:30:01 |
Re : Problème multithread

froggyinfo
|
Ok en fait tout s'éxécute bien en parallèle. Je pense que j'ai trouvé le problème. En fait la ou il y a un problème c'est dans les fonctions récup. Dans ces fonctions récup vous vous doutez bien que je ne fais que de mettre en veille des thread heureusement.
En fait dans ces thread j'appelle une fonction d'un web service. Et ce web service lui récupère le contenu html de page. Et en fait, j'ai l'impression qu'il fait les requêtes en série ce web service.
Est ce que vous connaissez un truc pour lancer deux requète différente en meme temps sur un serveur web.
Greg
|
|
Cette discussion est classée dans : system, console, thread, name, writeline
Répondre à ce message
Sujets en rapport avec ce message
Performances / CIL [ par MorpionMx ]
Bonjour a tous, J'ai envie de commencer la journée par une question de performance.Soit un programme minimaliste qui crée un entier i et qui l'affiche
problème avec thread jouant un son! [ par othland ]
slt tlm;je voulais concevoir un programme qui lance un thread qui lui même surveille l'horloge système pour lancer un son, le problème c'est que quand
déclarer un type word en c# [ par sheebe ]
Bonjour, je programme en ce moment en c# une carte à relais permettant d'actionner un gachette de porte pour mon projet de bts voici mon code:using S
WindowsForm et la console ? [ par vash_vador ]
Bonjour, Je suis nouveau dans le développements en c# (environ 6mois de pratique), et j'ai un projet mais j'ai un petit problème a résoudre: Mon probl
Newbie en C#, léger problème de sécurité avec VS2008.Net [ par Nixeus ]
Bonjour à tous,Je suis débutant dans le monde .Net, et je viens de faire un petit programme en console, permettant d'envoyer des Mails par le biais d'
Comment utiliser la commande EXIT en C# [ par sghchafaa ]
Bonjour;s'il vous plait,pouvez vous m'aider concernat la commande EXIT en C#;;je suis entrain de manipuler l'ecriture dans un fichier externe,,je veut
2ém probléme d'execution [ par sghchafaa ]
Sélém Alikom((signifie "Bonjour" en tunisien); voila c'est simple fonction qui cherche le careé ,mais sa marche pas!!!!!!!public class hello{ int
Parametrer le nembre des entier parés la virgule [ par sghchafaa ]
Sélém Alikom((signifie "Bonjour" en tunisien);j'ai pas pu faire un arrandissement de 3 entier parés la virgule, en effe,j'ai fait un tot petit program
Identification d'un client sur une appli client serveur en C# [ par dadew37 ]
Bonjour tout le monde !Je suis débutant en C#, et pourtant l'entreprise ou je suis me demande de développer une appli en C# qui gère du client serveur
SerialPort et SerialDataReceivedEventHandler [ par sebastienth ]
Bonjour à toutes et à tous, Électronicien de formation et débutant en C#, j'aurai aimé réaliser comme première application une communication de type
Livres en rapport
|
Derniers Blogs
UNE JOLIE-HORLOGE ET PAS QU'UN PEU !UNE JOLIE-HORLOGE ET PAS QU'UN PEU ! par neodante
Pour les possesseurs d'iPhone, ça y est Bijin Tokei - qui se traduit littéralement en Français par " Jolie Horloge " - est arrivé et GRATUITEMENT s'il vous plaît ! Après la version Tokyo, Hokkaido, night club, racing, Gal, "pour les mademoiselles'", . voi...
Cliquez pour lire la suite de l'article par neodante TECHDAYS PARIS 2010 : CONNECTEZ VOS DONNéES à SHAREPOINT 2010 AVEC LES BUSINESS CONNECTIVITY SERVICESTECHDAYS PARIS 2010 : CONNECTEZ VOS DONNéES à SHAREPOINT 2010 AVEC LES BUSINESS CONNECTIVITY SERVICES par ROMELARD Fabrice
Animé par: Gaetan Bouveret et Julien Chomarat Business Connectivity Services (BCS) est dans SharePoint 2010 la version 2 de Business Data Catalog (BDC dans SharePoint 2007). Il s'agit de la solution permettant de visualiser des données provenan...
Cliquez pour lire la suite de l'article par ROMELARD Fabrice [DIVERS] SUIVRE VOS SéRIES PRéFéRéS SUR LA TOILE[DIVERS] SUIVRE VOS SéRIES PRéFéRéS SUR LA TOILE par orion
Comme de nombreux geek, je suis un grand amateur de série TV et je rate régulièrement des épisodes de mes séries préférés. Une solution s'offre à vous avec ce merveilleux site : Tv Gorge - www.tvgorge.com Moteur de recherche à l'appui, vous pouvez ...
Cliquez pour lire la suite de l'article par orion TECHDAYS PARIS 2010 : LA BI DANS SHAREPOINT 2010TECHDAYS PARIS 2010 : LA BI DANS SHAREPOINT 2010 par ROMELARD Fabrice
Animé par: Vincent Bellet et Baptiste Giraudier La BI dans SharePoint 2010, Les nouveaux services d'application dans SP2010 et SQL Server Reporting services 2008 R2. La BI dans SharePoint est généralisée pour tous afin de permettre à tous les coll...
Cliquez pour lire la suite de l'article par ROMELARD Fabrice
Logiciels
DB-MAIN (9.1.0)DB-MAIN (9.1.0)DB-MAIN is a data-modeling and data-architecture tool. It is designed to help developers and anal... Cliquez pour télécharger DB-MAIN Xilisoft DPG Convertisseur (5.1.37.0120)XILISOFT DPG CONVERTISSEUR (5.1.37.0120)Xilisoft DPG Convertisseur offre aux fans de Nintendo DS une bonne solution leur permettant de dé... Cliquez pour télécharger Xilisoft DPG Convertisseur GraphicsGale (2.01.01)GRAPHICSGALE (2.01.01)GraphicsGale est un logiciel de PixelArt avec de nombreuse fonctionnalités permettant de réalisé ... Cliquez pour télécharger GraphicsGale Architecte 3D (Platinum 2010)ARCHITECTE 3D (PLATINUM 2010)Architecte 3D Platinium vous permet de concevoir facilement les plans votre future maison, de l'é... Cliquez pour télécharger Architecte 3D TeamViewer 5 (TeamViewer 5)TEAMVIEWER 5 (TEAMVIEWER 5)Dépanner un ami,expliquer une manipulation devient un jeu d'enfant.
Prise en main d'un autre ord... Cliquez pour télécharger TeamViewer 5
|