communication entre threads

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

Thread reader

Code:

---

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:

---

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.

Salut,

Citation:

---

Envoyé par dc.sara

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.

Citation:

---

Envoyé par dc.sara

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

---

Typique...

Citation:

---

Envoyé par dc.sara

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.

Citation:

---

Envoyé par dc.sara

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".