Discussion :

[Guillaume1701]

Bonjour,

Je débute sur l'utilisation des threads en c++. J'ai fait un petit exemple pour illustrer ce que je souhaite faire :

Code :

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

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
54
55
56
57
58
59
60
 
#include <thread>
#include <iostream>
#include <chrono>
#include <future>
 
class A
{
	public:
		A()
		{
			futureExit = exitSignal.get_future();
		}
 
		void launch()
		{
			m_thread = std::thread(&A::doWork, futureExit, std::ref(this));
			std::this_thread::sleep_for(std::chrono::seconds(30));
			exitSignal.set_value();
			m_thread.join();
		}
 
		void function1()
		{
			std::cout << "function1" << std::endl;
			my_variable++;
		}
 
		static void doWork(std::future<void> futureExit, A &oA)
		{
			std::cout << "doWork Start" << std::endl;
 
			while (futureExit.wait_for(std::chrono::milliseconds(1)) == std::future_status::timeout)
			{
				std::cout << "Work..." << std::endl;
				oA.function1();
				oA.my_variable2++;
				std::this_thread::sleep_for(std::chrono::milliseconds(1000));
			}
 
			std::cout << "doWork End" << std::endl;
		}
 
		int my_variable2;
 
	private:
		std::thread m_thread;
		std::promise<void> exitSignal;
		std::future<void> futureExit;
 
		int my_variable;
};
 
int main()
{
	A oA;
	oA.launch();
 
	return 0;
}

J'ai une thread qui travaille et qui a besoin de modifier des variables ou d'appeler des fonctions de la classe A. Avant je n'utilisai pas std::ref et je me suis rendu compte que je travaillai sur une copie de la classe A. Donc les changements dans le thread n'étaient pas visible dans la classe A.

Depuis que j'utilise std::ref, je n'arrive pas à compiler car j'utilise une fonction supprimée.

Avez-vous des conseilles ou des idées d'amélioration du code.

Merci d'avance

PS : Je suis en C++11

[dalfab]

Bonjour,

Ce n'est pas this qu'il faut passer par référence mais c'est *this.
Et la future elle aussi ne peut pas être passée par valeur, elle est dans this c'est inutile de la passer, sinon on pourrait aussi utiliser la référence.

[Garvelienn]

dalfab a raison. Par soucis pédagogique, je me permet d'expliquer un peu plus, si vous ne m'en voulez pas, dalfab

this est un pointeur sur l'instance de la classe. Ainsi, dans votre code, vous passez la référence d'un pointeur d'une instance de la classe. Ce n'est pas une erreur en soit mais vous ne l'utilisez pas comme une référence de pointeur ensuite : d'où votre erreur à la compilation. En donnant *this, vous passeriez en paramètre une référence de l'instance de la classe. * permettant d'accéder à ce que pointe le pointeur (ici une instance de la classe).

Pour la future, dalfab a déjà tout dit.

[Guillaume1701]

Merci de vos réponses.

Une autre petite question concernant la création d'une thread :
Est-il possible de passer "this" en utilisant la fonction pthread_create

Code :

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

1
2
ptrhead_t m_thread;
pthread_create(&m_thread, NULL, A::doWork, (void*)&this);

[Bousk]

C'est bien entendu possible vu que pthread_create demande un void*.
Et this est un T*, donc déjà un pointeur.
Mais je trouve ça un peu dommage d'utiliser pthread quand std::thread est similaire et disponible.

Enfin std::thread n'est pas utilisé correctement, ou plutôt de manière un peu absurde et sur-complexe.
m_thread = std::thread(&A::doWork, futureExit, std::ref(this)); pourrait et devrait s'écrire tout simplement m_thread = std::thread([this](){ DoWork(); });
Sinon si c'est pour faire un sleep suivi d'un join directement, le thread me semble des plus inutiles.

[Guillaume1701]

Sinon si c'est pour faire un sleep suivi d'un join directement, le thread me semble des plus inutiles.

Le code que j'ai mis me sert de test e ce n'est pas le code final. Mon but est de faire une thread de réception dans le cas d'une application client/server.

Code :

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

pthread_create(&m_thread, NULL, A::doWork, (void*)&this);

Quand j'utilise cette ligne de code j'ai une erreur à la compilation.

[Garvelienn]

Code :

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

pthread_create(&m_thread, NULL, A::doWork, (void*)&this);

Quand j'utilise cette ligne de code j'ai une erreur à la compilation.

Car vous faites encore la même erreur que dans le premier post. Je vous laisse chercher par rapport à ce qui a été dit précédemment.

La doc : http://man7.org/linux/man-pages/man3..._create.3.html

[Guillaume1701]

Car vous faites encore la même erreur que dans le premier post. Je vous laisse chercher par rapport à ce qui a été dit précédemment.

La doc : http://man7.org/linux/man-pages/man3..._create.3.html

Oui effectivement, j'ai encore fait la même erreur. Cependant avec la ligne suivante :

Code :

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

pthread_create(&(m_thread), NULL, &A::doWork, *this)

J'ai l'erreur :

Invalid conversion from 'void (*)(A&)' to 'void* (*)(void*)'
Cannot convert 'A' to 'void*'

Je commence à être un peu perdu là.

[ternel]

do_work n'est pas une fonction statique de A

Essaie donc pthread_create(&(m_thread), NULL, [this](){doWork()}, NULL).

[Bousk]

Ça ne marchera pas, [this](){doWork()} ne peut pas être converti en void* (*)(void*) requis par pthread à cause de la capture.
La syntaxe est pthread_create(&m_thread, NULL, &A::doWork, this); avec A::doWork déclarée comme static void* doWork(void*).
Aisément trouvable à peu près partout sur internet
http://lmgtfy.com/?q=pthread_create+example+c%2B%2B
http://man7.org/linux/man-pages/man3..._create.3.html
https://gist.github.com/fffaraz/83a1a133f1d257a6a98f

[ternel]

Et pthread_create(&(m_thread), NULL, [this](void* a){ return this->doWork(a);}, NULL) ?

Cela dit, la bonne réponse est probablement de rendre doWork static.

La raison profonde, c'est qu'une fonction membre non static n'est appelable que sur une donnée de sa classe.
Un pointeur de fonction membre d'une classe n'a pas la même forme qu'un pointeur de fonction libre (ou une fonction membre static).

[Bousk]

Tu as toujours une capture et donc la conversion est toujours impossible.