Discussion :

[Razgriz]

Bonjour à tous,

je viens de débuter la gestion de threads en C++, et je tente d'en stopper un. Je sais que la librairie ne permet pas de le faire et pourquoi. J'ai donc recours au code suivant minimal.

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
 
#include <iostream>
#include <chrono>
#include <thread>
 
using namespace std;
 
std::chrono::seconds sec(1);
 
class Runnable
{
    public:
        bool stop;
        Runnable(bool b = false) : stop(b) {}
 
        void operator()()
        {
            while(! stop)
            {
                cout << "Hello you" << endl;
                this_thread::sleep_for(sec);
            }
 
            cout << "Thread stopped" << endl;
        }
};
 
int main()
{
    Runnable r;
    thread t(r);
 
    bool stop = false;
    while(! stop)
    {
        cout << "Press anything to stop" << endl;
        char c;
        cin >> c;
        r.stop = true;
        this_thread::sleep_for(sec);
        stop = true;
    }
}

Néanmoins, quand je presse une touche, le threads qui affiche "Hello you" ne s'arrête pas, je ne vois pas "Thread stopped".

Qu'est-ce que je fais de mal ?

[bacelar]

Pour attendre la fin d'un thread c'est la méthode join :
http://www.cplusplus.com/reference/thread/thread/

Et le mot clé volatile est ton ami :
http://stackoverflow.com/questions/1...ad-shared-data

[Razgriz]

Pour attendre la fin d'un thread c'est la méthode join :
http://www.cplusplus.com/reference/thread/thread/

Je connais la méthode join et comment elle fonctionne. Toutefois, ajouter t.join() à la ligne 40 ne résoudra pas le problème (j'ai testé) vu que t ne s'arrête tout simplement pas, impressions à l'appui.

Et le mot clé volatile est ton ami :
http://stackoverflow.com/questions/1...ad-shared-data

Ajouter volatile à la variable stop (ligne 13) ne résout pas le problème. Notez que si je crée une fonction stop qui change la valeur de ce booléen, imprimer dans cette fonction la valeur du booléen après changement se passe correctement : le booléen a bien changé de valeur. Toutefois, au sein de operator(), ce changement n’apparaît pas (si on fait une impression à cet endroit là).

Merci d'avance pour vos réponses.

[fenkys]

Si tu rajoutes un cout dans le constructeur de Runable, tu comprendras instantanément ce qui se passe.

En bref, l'objet qui s’exécute dans le thread n'est pas celui que tu as créé, mais une copie de cet objet.

[Razgriz]

Ok... suis con ;-)

Voici comment résoudre le problème, pour les futurs cas similaires.

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
 
#include <iostream>
#include <chrono>
#include <thread>
 
using namespace std;
 
std::chrono::seconds sec(1);
 
class Runnable
{
    public:
        bool stop;
        Runnable(bool b = false) : stop(b) {}
 
        void operator()()
        {
            while(! stop)
            {
                cout << "Hello you" << endl;
                this_thread::sleep_for(sec);
            }
 
            cout << "Thread stopped" << endl;
        }
};
 
int main()
{
    Runnable r;
    thread t(ref(r));
 
    bool stop = false;
    while(! stop)
    {
        cout << "Press anything to stop" << endl;
        char c;
        cin >> c;
        r.stop = true;
        this_thread::sleep_for(sec);
        stop = true;
    }
}

[Iradrille]

Et le mot clé volatile est ton ami :
http://stackoverflow.com/questions/1...ad-shared-data

C'est un cadeau empoisonné. volatile n'a pas beaucoup d'amis.

Un std::atomic<bool> est généralement une meilleure approche. Même si j'imagine qu'un bool est de toute façon atomique donc les deux solutions reviendraient plus ou moins au même.

[Bousk]

C'est résolu mais dans le code initiale je ne vois aucun thread lancé.

[fenkys]

Mais si:

Code C++ :

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

thread t(r);

Ca correspond à ce prototype :

Code c++ :

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

1
2
template< class Function, class... Args >
explicit thread( Function&& f, Args&&... args );

qui "Creates new std::thread object and associates it with a thread of execution.". Le thread est donc bien lancé.