problème de création de thread

Version imprimable

1 pièce(s) jointe(s)

Bonjour,
utilisant d'habitude Qt, j'ai voulu tester la gestion des threads de la bibliothèque standard mais j'ai rencontré un problème. Voici un petit programme de test qui met ce problème en évidence:

source.cpp:
Code:

1 2 3 4 5 6 7 8 9 10 11 #include "testThread.h" #include <iostream> int main() { testThread test(5); return 0; }
testThread.h:
Code:

1 2 3 4 5 6 7 8 9 10 #pragma once class testThread { public: testThread(int param); private: void runThread(); int itr; };
testThread.cpp:
Code:

1 2 3 4 5 6 7 8 9 10 11 12 13 14 #include <thread> #include <iostream> #include "testThread.h" testThread::testThread(int param):itr(param) { std::thread myThread(&testThread::runThread, this); } void testThread::runThread() { for (int i = 0; i < itr; i++) std::cout << "hello" << std::endl; }
La classe testThread lance donc un thread qui affiche hello autant de fois que la valeur du paramètre passé lors de son instanciation.

Cependant, même si l'affichage final est correct, j'obtiens le message d'erreur joint en mode debug:

En mode release, le programme crashe.

Je travaille avec visual studio 2013.

merci à ceux qui prendront le temps de lire ce message et pourront m'apporter une solution.

23/09/2017, 18h04
jackk

Honte à moi.
C'est juste que le programme se terminait avant le thread.
23/09/2017, 19h57
Bousk

Salut,

tu as trouvé ton erreur, mais il y a à redire sur ton code.
Le plus important est que si ta classe est sensé encapsuler un thread, il faudrait que le thread soit en variable membre.
Là tu crées un thread que tu ne contrôles absolument plus dès la sortie du constructeur.
Ca te permettrait de pouvoir le join pour que le programme s'arrête proprement.

Merci pour tes remarques, je suis toujours preneur.

En fait c'était juste une version minimale pour mettre le problème en évidence. la version que j'utilise finalement ressemblera plutôt à ceci:

Code:

1
2
3
4
5
6
7
8
9
10
11
#include "testThread.h"
#include <iostream>
 
int main()
{
    testThread test(5);
    test.start();
    test.wait();
 
    return 0;
}

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
#pragma once
#include <thread>
 
class testThread
{
public:
    testThread(int param);
    void start();
    void wait();
 
private:
    std::thread myThread;
    int itr;
 
    void runThread();
};

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
#include <iostream>
#include "testThread.h"
 
testThread::testThread(int param):itr(param)
{
}
 
void testThread::runThread()
{
    for (int i = 0; i < itr; i++)
        std::cout << "hello" << std::endl;
}
 
void testThread::start()
{
    myThread = std::thread(&testThread::runThread, this); // Lance le thread
}
 
 
void testThread::wait()
{
    if (myThread.joinable())
        myThread.join();
}

Cà te semble cohérent?