[Boost.Thread] modifier un objet

Version imprimable

Bonjour à tous!
Toujours pour m'initier à Boost.Thread, j'essaie actuellement de construire un Compteur dans un thread, que je remet à zéro dans le programme principal de temps en temps.

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
#include <iostream>
#include <string>
#include <limits>
 
#include <boost/thread/thread.hpp>
#include <boost/bind.hpp>
 
class Compteur
{
public :
	Compteur(std::string nom) : m_compteur(0), m_nom_compteur(nom), continuer(true) {std::cout << "Creation d'un compteur : " << m_nom_compteur << std::endl;}
 
	void incrementer();
	void afficher() { std::cout << m_nom_compteur << " : " << m_compteur << std::endl; }
	void reset() {m_compteur = 0;}
 
private:
	int m_compteur;
	std::string m_nom_compteur;
	bool continuer;
};
 
void Compteur::incrementer()
{
	while (continuer == true) {
		m_compteur++;
		afficher();
	}
}
 
 
int main()
{
	Compteur comp1("Compteur 1");
	boost::thread compteur1(boost::bind(&Compteur::incrementer, comp1));
 
	int i = 0;
	while(1)
	{
		if (i == 1000)
		{
			comp1.reset(); // Ne marche pas
			std::cout << "Remise a Zero" << std::endl;
			std::cout << "Appuyez sur entree pour continuer...";
			std::cin.ignore( std::numeric_limits<std::streamsize>::max(), '\n' );
			i = 0;
		}
		i++;
		std::cout <<"i = " << i << std::endl;
	}
 
	return 0;
}

Le problème est que je fourni au thread une fonction membre qui est interprétée comme une fonction et rien d'autre. Le fait d'appeler reset() ne va rien changer au fait que le compteur va continuer de s'incrémenter... :aie:

Question : comment faire pour modifier l'objet ? :?

:merci:

25/08/2007, 14h40
loufoque

Normal, y'a des problèmes de concurrence...
Tu ne peux pas simplement partager une variable entre plusieurs threads.
25/08/2007, 18h26
poukill

Comment pourrait-on remettre à 0 le compteur qui se trouve dans un autre thread?
25/08/2007, 19h23
Matthieu Brucher

Il faut mettre un mutex et stocker une référence vers ton compteur dans le thread principal et dans l'autre thread.
25/08/2007, 19h39
poukill

Ok je vais essayer. Juste une question, quand je fais :

Code:

boost::thread compteur1(boost::bind(&Compteur::incrementer, comp1));

Est-ce que la fonction incrementer() est "liée" à l'objet comp1, ou bien la fonction incrementer vie sa vie toute seule? :koi:
25/08/2007, 19h55
Matthieu Brucher

Elle est liée à comp1, naturellement ;)
25/08/2007, 22h17
HanLee

Citation:

Envoyé par Miles

Elle est liée à comp1, naturellement ;)

Non, la doc de boost::bind indique qu'ici qu'une copie interne de "comp1" est effectuée.

Pour qu'elle soit liée à comp1, il faut lui donner un pointeur vers comp1, ou bien utiliser boost::ref. Je me suis déjà fait piéger comme ça :aie:.
25/08/2007, 22h33
Matthieu Brucher

Ah ? Zut, planté. En revanche, si on spécifie un passage par référence devrait fonctionner, non ?
26/08/2007, 00h03
HanLee

Citation:

Envoyé par Miles

Ah ? Zut, planté. En revanche, si on spécifie un passage par référence devrait fonctionner, non ?

En remplaçant ça :

Code:

boost::bind(&Compteur::incrementer, comp1)

par l'un des 2 au choix :

Code:

boost::bind(&Compteur::incrementer, &comp1)

Code:

boost::bind(&Compteur::incrementer, boost::ref(comp1))

Après si avec les threads ça marche... ?
26/08/2007, 12h31
poukill

Merci beaucoup ! Du coup, mon programme fonctionne avec boost::ref. Le comp1.reset() remet bien à zéro l'attribut m_compteur, et comme il n'y a pas de copie, ça marche.

:merci: