Discussion :

[dc.sara]

Bonjour,
j'ai un petit problème,
J'ai deux threads qui fonctionnent suivant le modèle producteur/Consommateur. un thread qui attend sur un select, une fois qu'il recoit quelque chose, il la met dans une FIFO. et un autre thread qui lit à partir de la FIFO. Pour cela dans chacun des threads, j'utilise une boucle infinie de type while(true). Pour le premier thread qui fait la réception, j'ai pas de problème car le select est bloquant. Par contre pour le thread qui lit à partir de la FIFO, mon problème que le thread teste toujours la FIFO pour voir s'il y a de nouvelle données du coup mon utilisation CPU est toujours de 90%. J'ai essayé d'utiliser le pthread_cond_t pour régler ca en programmant en C++, mais j'arrive pas.
Svp, y a t'il une autre façon de faire ca ?

Merci bcp

Sara

[ram-0000]

Thread reader

Code :

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

1
2
3
4
5
6
7
8
 
pour toujours
   attendre evenement
   tant que FIFO pas vide
      lire FIFO
      traiter message lu
   fin tant que
fin pour toujours

thread writer

Code :

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

1
2
3
4
5
 
...
ajouter message dans FIFO
signaler evenement
...

L'evenement que j'utilise sous Microsoft est créé par CreateEvent()
http://msdn2.microsoft.com/en-us/lib...96(VS.85).aspx et cela marche très bien

Si tu es sous une autre plateforme, il doit exister un équivalent (peut être chez boost)

Par contre, ne pas oublier de protéger la FIFO par une section critique car 2 thread peuvent tenter d'y accéder simultanément.

[Mat007]

Salut,

Svp, y a t'il une autre façon de faire ca ?

Tu peux utiliser Boost.Asio qui gère tout ça pour toi.

MAT.

[corrector]

J'ai deux threads qui fonctionnent suivant le modèle producteur/Consommateur.

Typique...

Par contre pour le thread qui lit à partir de la FIFO, mon problème que le thread teste toujours la FIFO pour voir s'il y a de nouvelle données du coup mon utilisation CPU est toujours de 90%.

Comment est définie ta FIFO? Comment synchronises-tu les deux threads?

Montre-nous le code qui sert à manipuler la FIFO.

J'ai essayé d'utiliser le pthread_cond_t pour régler ca en programmant en C++, mais j'arrive pas.

Une condition pthread peut effectivement servir à signaler que des données sont présentes, c'est même l'exemple canonique d'utilisation des "variables de condition".