Forum |  HardWare.fr | News | Articles | PC | S'identifier | S'inscrire | Shop Recherche
1289 connectés 

  FORUM HardWare.fr
  Programmation
  C

  [C] Producteur/consommateur avec threads en C sur liste chainée...

 
 


 Mot :   Pseudo :  
 
Bas de page
Auteur Sujet :

[C] Producteur/consommateur avec threads en C sur liste chainée...

n°543072
Tetedeienc​h
Head Of God
Posté le 19-10-2003 à 13:06:02  profilanswer
 

Hello :)
 
Ca fait un bail que j'ai pas bossé sur les mutex et compagnie, donc il me faudrait une peu d'aide sur quelque chose d'assez bidon.
 
Le schema de mon programme est un processus maitre qui est producteur et X threads qui sont consommateurs.
 
Le process maitre remplit une liste chainée, les threads la vident et traitent les demandes.
 
La ou je me pose des question, c'est dans le cas ou la liste est vide.
 
je m'explique : pour l'instant, pour qu'un thread puisse faire un pop d'un job sur la liste, il doit réussir a locker l'mutex.
 
Il ferme le mutex, prends son job, rouvre le mutex.
 
Seulement voilà, avec une archi pareille, les fils vont prendre en boucle les mutex meme si la liste est vide. En gros, il faudrait que, si la liste est vide, que le maître puisse la remplir a nouveau.
 
Etaussi, que le maitre aie priorité sur le remplissage de la liste face aux consommateurs.
 
Comment vous réaliseriez cela, pour avoir des performances optimales ?
 
merci :jap:

mood
Publicité
Posté le 19-10-2003 à 13:06:02  profilanswer
 

n°543074
Taz
bisounours-codeur
Posté le 19-10-2003 à 13:14:07  profilanswer
 

en fonction de la bibliothèque que tu utilises, tu doit pourvoir trouver quelque chose pour gérer les conditions, des attentes conditionnelles

n°543095
Tetedeienc​h
Head Of God
Posté le 19-10-2003 à 13:53:12  profilanswer
 

j'utilise pthread.d ... donc oui j'ai une condition ( pthread_cond_t et compagnie...)
 
Mais je mets quoi comme condition :??:
 
Et surtout, je voius moyennement comment ca marche... y a un exemple la, mais je vois pas pourquoi les autres doivent attendre ...
 
http://monge.univ-mlv.fr/~roussel/ [...] rs_ex.html

n°543096
Taz
bisounours-codeur
Posté le 19-10-2003 à 13:53:53  profilanswer
 
n°543098
Tetedeienc​h
Head Of God
Posté le 19-10-2003 à 14:03:38  profilanswer
 

mmmmh...
 
Donc si je mets une condition "liste non vide", tout mon truc marche parfaitement... c'est bien ca ?  
 
Donc l'algo ca va etre ( si j'ai bien capté ).
 
Maitre :

Citation :

attends requete
requete arrivée, lock mutex de la liste
ajout requete liste
delock mutex
signal condition OK
goto debut


 
esclave

Citation :

prends mutex + condition
pop job de la liste  
delock mutex
goto debut


 
C'est bien ca ou j'ai faux ? J'ai du mal a saisir le concept, j'avoue :/

n°543099
Tetedeienc​h
Head Of God
Posté le 19-10-2003 à 14:05:46  profilanswer
 

nan ca doit pas etre ca :/
 
Rah j'arrive pas a capter le truc des conditions :/ Ca s'apelle condition mais ca amrche comme un signal ?

n°543100
Taz
bisounours-codeur
Posté le 19-10-2003 à 14:06:15  profilanswer
 

voilà
 
un exemple 1 - 1 en C++
http://boost.org/libs/thread/example/condition.cpp

n°543103
Tetedeienc​h
Head Of God
Posté le 19-10-2003 à 14:10:03  profilanswer
 

Taz a écrit :

voilà
 
un exemple 1 - 1 en C++
http://boost.org/libs/thread/example/condition.cpp


 
Euh... c'est du chinois la :lol:
 
:sweat:  
 
Enfin je pense que j'ai mon idée... je vais reprendre l'exemple bcp + simple qui se trouve la : http://monge.univ-mlv.fr/~roussel/ [...] rs_ex.html
 
Et faire le même schéma de communication .
 
je pense qu'il s'applique a mon problème.


Message édité par Tetedeiench le 19-10-2003 à 14:10:25
n°543104
Tetedeienc​h
Head Of God
Posté le 19-10-2003 à 14:15:05  profilanswer
 

En fait, il faudrait que je fasse un truc de "priorité", dans le genre :
 
maître :
-attente requete
-lock mutex
-ajout requete dans liste
-condition remplie ( on vient d'en ajouter un...)
-delock mutex
 
esclave :
-essai lock mutex si condition remplie
-prendre requete
-si liste pas vide alors condition remplie
-delock mutex
-traitement requete
 
Dans ce cas la, je pense que cela marche, non ?  
 
Ton avis taz ?

n°543110
Taz
bisounours-codeur
Posté le 19-10-2003 à 14:41:14  profilanswer
 

tout ça ne peut pas bien marcher puisqu'une condition doit etre associée à un mutex pour avoir le bon comportement

mood
Publicité
Posté le 19-10-2003 à 14:41:14  profilanswer
 

n°543111
Taz
bisounours-codeur
Posté le 19-10-2003 à 14:43:44  profilanswer
 

le moindre usage doit ressembler à ça
 

Code :
  1. pthread_mutex_lock(&resume_condition_mutex);
  2. pthread_cond_wait(&resume_condition, &resume_condition_mutex);
  3. pthread_mutex_unlock(&resume_condition_mutex);


 
et de l'autre coté (ici en broadcast
 

Code :
  1. pthread_mutex_lock(&resume_condition_mutex);
  2. pthread_cond_broadcast(&resume_condition);
  3. pthread_mutex_unlock(&resume_condition_mutex);

n°543114
Tetedeienc​h
Head Of God
Posté le 19-10-2003 à 14:55:36  profilanswer
 

Voilà ce que j'ai fait ( en version rapidos hein, ca fait 2 ans que j'ai pas fait de C )
 

Code :
  1. /****************************************************************************************/
  2. /***                                       ESCLAVES                                   ***/
  3. /****************************************************************************************/
  4. void* thfunc(void* id)
  5. {
  6.   httpjob* curjob;
  7.   printf("Thread %d\n",id);
  8.   while (1)
  9.     {
  10.       pthread_cond_wait(&jlist_cond,&jlist_mutex);
  11.       curjob = pophead();
  12.       pthread_mutex_unlock(&jlist_mutex);
  13.       printf("thread %d got job %d\n",id,curjob->num);
  14.       free(curjob);
  15.     }
  17. }
  22. /****************************************************************************************/
  23. /***                                   PROCESSUS MAITRE                               ***/
  24. /****************************************************************************************/
  25. int main(char* argv[],int argc)
  26. {
  27.   FILE* f;
  28.   int i,numjob;
  29.   httpjob* job;
  30.   pthread_t id;
  32.   //Initialisation variables globales. Le NULL sert a avoir les attributs par d?éfaut.
  33.   jlist.head = jlist.tail = NULL;
  34.   pthread_mutex_init(&jlist_mutex,NULL);
  35.   pthread_cond_init(&jlist_cond,NULL);
  38.   //  f = fopen("config.c","rw" );
  39.   for (i=0;i<5;i++)
  40.     pthread_create(&id,NULL,thfunc,(void*) i);
  42.   printf("Waiting for numbers\n" );
  43.   while (1)
  44.     {
  45.       scanf("%d\n",&numjob);
  46.       job = (httpjob*) malloc (sizeof(httpjob));
  47.       job->num = numjob;
  48.       job->next = NULL;
  50.       pthread_mutex_lock(&jlist_mutex);
  51.       printf("mutex locked\n" );
  52.       addjobinlist(job);
  53.       printf("job added\n" );
  55.       pthread_mutex_unlock(&jlist_mutex);
  57.       pthread_cond_signal(&jlist_cond);
  58.     }
  59.    
  60.    
  61.   return 1;
  63. }


 
Ca a l'air de bien marcher...
 
Enfin j suis sur que taz va me dire que la syntaxe est moche, désolé par avance :/


Message édité par Tetedeiench le 19-10-2003 à 14:56:11
n°543118
Taz
bisounours-codeur
Posté le 19-10-2003 à 15:01:43  profilanswer
 

voir mon message précédent, lire les man
 
sinon tu peux tout initialisé statiquement, lis les man

n°543121
gilou
Modérateur
Modzilla
Posté le 19-10-2003 à 15:06:05  profilanswer
 

tetedeiench a écrit :

Voilà ce que j'ai fait ( en version rapidos hein, ca fait 2 ans que j'ai pas fait de C )


Tu ne fais plus que du VB?  :whistle:  
A+,


---------------
There's more than what can be linked! --    Iyashikei Anime Forever!    --  AngularJS c'est un framework d'engulé!  --
n°543123
Tetedeienc​h
Head Of God
Posté le 19-10-2003 à 15:09:04  profilanswer
 

Taz a écrit :

voir mon message précédent, lire les man
 
sinon tu peux tout initialisé statiquement, lis les man


Ben, quelle est la différence avec ce que j'ai fait :??:
 
je vois pas :??:

n°543126
Taz
bisounours-codeur
Posté le 19-10-2003 à 15:13:30  profilanswer
 

enchasse les opérations cond* dans le mutex associé, comme dit dans le man

n°543131
Tetedeienc​h
Head Of God
Posté le 19-10-2003 à 15:20:03  profilanswer
 

Taz a écrit :

enchasse les opérations cond* dans le mutex associé, comme dit dans le man


Voilà le souci : ca veut rien dire pour moi ca.
 
Détaille, je vois rien la dessus dans les différents mans ( tu penses que je les ai lus avant de poster :/ )

n°543138
Tetedeienc​h
Head Of God
Posté le 19-10-2003 à 15:41:02  profilanswer
 

D'ailleurs, d'après ce lien, j'ai utilisé ca pas si mal que ca, nan ?
 
http://monge.univ-mlv.fr/~roussel/ [...] linux.html
 
Evidemment y a le traitement qui jouera apres, mais bon... ca m'a l'air bon ?
 
je vois pas ce que tu veux dire taz :??:


Message édité par Tetedeiench le 19-10-2003 à 15:41:19
n°544249
Taz
bisounours-codeur
Posté le 19-10-2003 à 19:25:38  profilanswer
 

lis le man, vois l'exemple. il faut enchasser tout ça, pthread_cond srentre dans el mutex si la condition est vérifiée.

n°544256
Tetedeienc​h
Head Of God
Posté le 19-10-2003 à 19:35:34  profilanswer
 

BELENG !
 
Vla que je tilte ce que tu voulais dire par "enchâsser".
 
mais dans mon cas, faut pas que j'enchasse !
 
Le signal est la pour leur dire qu'ils peuvent se battre pour le mutex justement, car j'ai besoin que le mutex soie libre pour que le maître ajoute un élément à la liste ;)
 
Donc je les fait attendre sur le cond, des que cond est vrai, y en a un et un seul qui va passer ( et remettre la cond a false) et prendre le mutex et hopla :)
 
nan ?

n°544262
Taz
bisounours-codeur
Posté le 19-10-2003 à 19:42:30  profilanswer
 

ben c'est une utilisation canonique. sinon tu risques d'avoir des problèmes. le mutex que tu passe en param, quand la condition est vérifiée il rentre, sinon il le libère. donc sans l'enchassement, ça peut merdoyer

n°544272
Tetedeienc​h
Head Of God
Posté le 19-10-2003 à 19:48:45  profilanswer
 

exact...
 
Crotte, en plus, je viens de me rendre compte que ca marche pas dans mon cas, faut que je revoie ma condition :(

n°544276
Tetedeienc​h
Head Of God
Posté le 19-10-2003 à 19:51:29  profilanswer
 

Parce que si j'enchasse, alors forcément il faut que je fasse deux mutex, un pour le maitre, un pour les esclaves...
 
Car si un esclave tiens le mutex, le maitre ne peut le prendre... et donc tlm attends comme des cons, deadock.
 
Donc, il me faut deux mutex ... sur la même liste :??: :??: :??: c'est débile. et ca marchera pas ( deux mutex libérés en meme temps = aie ).
 
La je vois pas comment faire :cry: C'est plus au niveau condition mais au niveau algorithmique la :/

n°544302
Tetedeienc​h
Head Of God
Posté le 19-10-2003 à 20:08:13  profilanswer
 

j'ai trouvé, me faut un sémaphore, pas moyen autrement.
 
Le semaphore contenant le nombre d'emplacement occupé dans la liste...
 
J'enchaine le sémaphore + le mutex et ca marchera...

n°544318
Tetedeienc​h
Head Of God
Posté le 19-10-2003 à 20:22:46  profilanswer
 

Voilà le code avec le sémaphore, et ca a l'air d'etre bon :)
 

Code :
  1. /****************************************************************************************/
  2. /***                                       ESCLAVES                                   ***/
  3. /****************************************************************************************/
  4. void* thfunc(void* id)
  5. {
  6.   httpjob* curjob;
  7.   printf("Thread %d\n",id);
  8.   while (1)
  9.     {
  10.       sem_wait(&jlist_sem);
  11.       pthread_mutex_lock(&jlist_mutex);
  12.       curjob = pophead();
  13.       pthread_mutex_unlock(&jlist_mutex);
  14.       printf("thread %d got job %d\n",id,curjob->num);
  15.       free(curjob);
  16.     }
  18. }
  23. /****************************************************************************************/
  24. /***                                   PROCESSUS MAITRE                               ***/
  25. /****************************************************************************************/
  26. int main(char* argv[],int argc)
  27. {
  28.   int i,numjob;
  29.   httpjob* job;
  30.   pthread_t id;
  31.   char* param;
  33.   parseconfig();
  35.   //Initialisation variables globales. Le NULL sert a avoir les attributs par d?éfaut.
  36.   jlist.head = jlist.tail = NULL;
  37.   pthread_mutex_init(&jlist_mutex,NULL);
  38.   sem_init(&jlist_sem,0,0);
  40.   for (i=0;i<5;i++)
  41.     pthread_create(&id,NULL,thfunc,(void*) i);
  43.   printf("Waiting for numbers\n" );
  44.   while (1)
  45.     {
  46.       scanf("%d\n",&numjob);
  47.       job = (httpjob*) malloc (sizeof(httpjob));
  48.       job->num = numjob;
  49.       job->next = NULL;
  51.       pthread_mutex_lock(&jlist_mutex);
  52.       printf("mutex locked\n" );
  53.       addjobinlist(job);
  54.       printf("job added\n" );
  55.       sem_post(&jlist_sem);
  56.       pthread_mutex_unlock(&jlist_mutex);
  57.     }
  58.    
  59.    
  60.   return 1;
  62. }


 
Je sais, c'est du code moche :/

mood
Publicité
Posté le   profilanswer
 


Aller à :
Ajouter une réponse
  FORUM HardWare.fr
  Programmation
  C

  [C] Producteur/consommateur avec threads en C sur liste chainée...

 

Sujets relatifs
[Java] Threads(simple mais je capte pas )[C] Liste chaînée / pointeur : problème !
[vb] programme qui liste les sous dossiers d un dossier[thread/linux/c++/kdevelop3.1] Problème avec les threads
liste d'imagesprobleme de liste deroulante
[Javascript] modification d'une liste déroulante via bouton radio[C++] Optimisation de recherche d'un critere ds une liste
[windows] recuperer la liste des fichiers *.txt dans un repertoire 
Plus de sujets relatifs à : [C] Producteur/consommateur avec threads en C sur liste chainée...

Forum MesDiscussions.Net, Version 2010.2
(c) 2000-2011 Doctissimo
Page générée en 0.089 secondes

Copyright © 1997-2022 Hardware.fr SARL (Signaler un contenu illicite / Données personnelles) / Groupe LDLC / Shop HFR