Stopper la fonction exécutée par un thread avec un attribut

Version imprimable

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:

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 ?

13/01/2016, 16h51
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
13/01/2016, 17h03
Razgriz

Citation:

Envoyé par bacelar

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.

Citation:

Envoyé par bacelar

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.
13/01/2016, 17h09
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.

Ok... suis con ;-)

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

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
 
#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;
    }
}

13/01/2016, 17h39
Iradrille

Citation:

Envoyé par bacelar

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.
13/01/2016, 17h55
Bousk

C'est résolu mais dans le code initiale je ne vois aucun thread lancé. :weird:
18/01/2016, 16h01
fenkys
Mais si:

Code:

thread t(r);

Ca correspond à ce prototype :
Code:

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