Discussion :

[MikeLarson]

Bonjour,

J'ai cherché à utiliser boost seulement j'ai une question : comment puis-je faire communiquer 2 threads de telle sorte que le premier envoi une message du type "send:event:toTh8:param:ID'5'", en gros une chaine de caractère?
Au début je pensais utiliser une mémoire partagée avec un mutex pour gérer la lecture/écriture. Seulement j'aimerais pouvoir endormir un thread et que celui-ci ne se réveil que si il recoit un signal, exemple :

Code :

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

1
2
3
4
5
6
7
8
9
10
11
12
void funcTh1(){
...
...
wait(signal);
...
}
 
void funcTh2(){
...
sen_signal(toTh2, myMessage);
...
}

Je ne sais pas si je me fais comprendre.

En tout cas si un tutaux existe dèja sur mon problème précis je m'excuse pour mon manque de recherche.

Merci d'avance!!!!

[Ekleog]

pthread dispose d'un mécanisme de conditions (cf. un tuto à ce sujet sur ce même site).

Après, tout dépendra de la librairie que tu utilises.

[MikeLarson]

Bonjour, j'utilise toute celle qui sont dans boost.

[MikeLarson]

Do c je n'utilise pas pthread mais plutôt boost::thread et toutes les librairies de boost que je peu avoir ^^

[DonQuiche]

Bonjour.

La mémoire partagée (shared memory) est réservée à la communication inter-processus. Pour de la communication inter-threads, rien de particulier n'est nécessaire puisque tous les threads ont accès à l'intégralité de la mémoire du processus. On pourra par exemple stocker l'info à partager dans une variable statique ou passer un pointeur vers l'emplacement partagé en argument au démarrage du thread.

Concernant la "mise en sommeil jusqu'à ce que...", on utilise des condition variables. Pour Boost, voici l'exemple de la doc officielle. Note l'appel à "cond.wait" dans un thread et "cond.notify_one" dans un autre.

[MikeLarson]

Merci pour la réponse!

Par contre si j'ai bien compris :

mutex mutexLocker;

- Communication entre thread1 et thread 2 :
condition_variable cond1;
void funcTh1(){
unique_lock<boost::mutex> lock(mutexLocker);
...
// Endormissement du thread
cond1.wait(lock);
....

void funcTh2(){
...
// envoi de signal => débloquage de Th1
cond1.notify_one();

Si je veux faire de même entre Th1 et Th3 je créai un autre condition_variable? et/ou un autre mutex? A mon avis je dirais oui.

Merci en tout cas pour l'aide.

Bonne journée.