Comment arrêter un thread de travail ? (version FAQ)

Salut,

Je sais pas si c'est parce qu'il est tard, mais j'ai un peu de mal avec la solution présenté par la FAQ pour arrêter un thread.
Est-ce que ca permet bien de pouvoir stopper un thread en cours quand on veut?

Si oui, un petit exemple siouplé.

Merci

Un petit lien vers la FAQ n'aurait pas fait de mal.

Donc ici :http://c.developpez.com/faq/vc/?page...opWorkerThread

Le principe est simple:
Dans la fonction du thread, on sort de la boucle si un evènement spécifique est signalé.

Code:

---

1 2 3 4 5 6 7 8 9 10 11 12

while(true) { // attente evenement de fin du thread. -> l’objet doit être ‘signalé ‘ // WaitForSingleObject renvoie WAIT_OBJECT_0 si l’objet est signalé. if(::WaitForSingleObject(pThis->m_EndThread, 0) == WAIT_OBJECT_0)   { // signale l'objet event d'attente et sort. ::SetEvent(pThis->m_WaitThread); return 0; }

---

Losrque l'application veut tuer le thread, elle force l'évènement de terminaison du thread en appellant explicitemant le destructeur de l'objet CWorkerThread.

Code:

---

1 2 3 4 5 6

// declenche la fin du thread ::SetEvent(m_EndThread);   // attend que le thread soit terminé ::WaitForSingleObject(m_WaitThread, INFINITE);

---

Enfin, ce n'est pas la seule méthoe, tu peux aussi te pencher du côté de TerminateThread.

re,
Bien il me semble que le post était clair non ?
Attention a terminatethread voir l’avertissement sur la libération mémoire .
:D

J'avoue que concernant l'utilisation j'avais beaucoup de doutes... :oops:

:arrow: J'ai un problème à la compilation concernant la ligne :

Code:

---

AfxBeginThread(ThreadFunction, this);

---

J'obtiens toujours l'erreur :

Citation:

---

'AfxBeginThread' : none of the 2 overloads can convert parameter 1 from type 'unsigned int (void ** )'

---

Tu as simplement créer ton projet SANS les MFC !

Dans ce cas, il te reste deux choix:
- recréer le projet avec les MFC.
- Oublier la classe CThread et repartir de l'API Windows pûre.

Pour Farscape: Oui, il faut effectivement faire attention aux problèmes de libération de mémoire. Dans le même temps, j'ai indiqué ça surtout s'il n'utilisait pas le MFC, j'ai manqué de clarté.

En remplacant

Code:

---

ThreadFunction(LPVOID* pvParam)

---

par

Code:

---

ThreadFunction(LPVOID pParam)

---

Ca fonctionne...

Pour pouvoir passer plusieurs parametre à mon Thread j'ai essayé ca :

Classe:

Code:

---

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21

class CWorkerThread { ... private: ... struct Parameters{ CWorkerThread* pWorkerThread; CProject* pProject; }; Parameters arg; ... };   CWorkerThread::CWorkerThread() { ... arg.pWorkerThread=this; arg.pProject=NULL;   AfxBeginThread(ThreadFunction, &arg); }

---

ThreadFunction :

Code:

---

1 2 3 4 5 6 7 8 9 10 11 12 13

UINT CWorkerThread::ThreadFunction(LPVOID pParam) { CWorkerThread *pThis = static_cast<Parameters*>(pParam)->pWorkerThread; CProject *pProject = static_cast<Parameters*>(pParam)->pProject;   while(true) { .... // Votre code de traitement. if(pProject) pProject->start(); } return 0; }

---

Mais ca ne fait que planter...

Citation:

---

memory could not be "read"

---

Quand j'essaye d'accéder à pProject ou pThis...

salut
vu ton code ça me semble normal.
dans ton constructeur tu as arg.pProject=NULL;
et apres tu tentes d'utiliser le pointeur dans ton thread ,mais la valeur est toujours a null ,d'ou le plantage.
:D

Pourtant j'avais bien penser à tester si le pointeur n'est pas nul :

Code:

---

if(pProject) pProject->start();

---

Je viens de tester autrement, en déclarant arg comment un pointeur :

Code:

---

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22

class CWorkerThread { ... private: ... struct Parameters{ CWorkerThread* pWorkerThread; CProject* pProject; }; [b]Parameters* arg; [/b] ... };   CWorkerThread::CWorkerThread() { ... arg = new Parameters; arg->pWorkerThread=this; arg->pProject=NULL;   AfxBeginThread(ThreadFunction, arg); }

---

Et cette fois ca fonctionne !.

:?: Est-ce que précédemment : static_cast<Parameters*>(pParam) était valable alors que j'avais passé en paramètre &arg ?

:?: Est-ce que la solution de la FAQ (UINT ThreadFunction(LPVOID* pvParam)) ne marche vraiment pas, ou est-ce que j'ai mal fait quelque chose ?

Cain :

Citation:

---

Tu as simplement créer ton projet SANS les MFC !

---

Là t'as visiblement faux... :wink:

Citation:

---

Losrque l'application veut tuer le thread, elle force l'évènement de terminaison du thread en appellant explicitemant le destructeur de l'objet CWorkerThread

---

http://arb.developpez.com/smileys/hum.gif
faut pas appeler explicitement un destructeur, sauf cas très particulier. http://c.developpez.com/faq/cpp/?pag...teur_explicite

Dans ma classe CProcessDlg (CDialog) j'ai un membre privé : CWorkerThread* m_threadStart;

Dans BOOL CProcessDlg::OnInitDialog() je crée mon CWorkThread en passant en parametre mon Projet :

Code:

---

m_threadStart = new CWorkerThread(pMyProjectDoc->getProject());

---

Tout va bien,

Code:

---

if(pProject) pProject->start();

---

s'exécute bien dans le thread.

Quand je clique sur le bouton "Annuler" de mon CDialog, je veux arrêter le thread.

Code:

---

1 2 3 4 5 6

void CProcessDlg::OnCancel() { delete m_threadStart;   CDialog::OnCancel(); }

---

"delete m_threadStart;" doit normalement appelé le destructeur de CWorkerThread, et donc arrêter le thread comme prévu...

:arrow: Ca ne fonctionne pas, mon thread tourne en boucle... et je suis obligé de le killer...

:help:

re,
En fait le post est erroné dans la faq il y eu un mélange de code la fonction du thread doit être bien statique a la classe.
la version corrigée serait:

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

class CMyDialog : public CDialog { public: CMyDialog(CWnd* pParent = NULL) : CDialog(100, pParent) { m_pThread = NULL; }   bool InitThread() { m_pThread = AfxBeginThread(ThreadFunc, this); if(!m_pThread) { // Impossible de créer le thread ! return false; } return true; }   private: CWinThread *m_pThread;   static UINT ThreadFunc(LPVOID pvParam); }; UINT CMyDialog::ThreadFunc(LPVOID pvParam) { CMyDialog *pThis=static_cast< CMyDialog *>( pvParam) ; // Votre code // return 0 ; }

---

:D

En fait il faut complètement "oublier" la classe CWorkerThread du post de la FAQ et intégrer directement toutes ses fonctionnalités à CMyDialog.
C'est bien ca ?

Citation:

---

Envoyé par loupdeau

En remplacant

Code:

---

UINT ThreadFunction(LPVOID* pvParam)

---

par

Code:

---

UINT CWorkerThread::ThreadFunction(LPVOID pParam)

---

Ca fonctionne...

---

Autant pour moi, j'avais pas vu :)

Normal, une méthode d'objet est toujours utilisé comme suit : NomObjet::Methode_objet(liste arguments).

Et justement StdAfxBeginThread attend un pointeur vers la fonction de traitement.

C'est bon aussi dans la thread, c'est juste que le prototype de la FAQ est erroné : LPVOID* au lieu de LPVOID.

Comme ça m'est arrivé avec un thread de traitement, je pense utile de pévenir notre ami de ce problème:

si le thread est réellement bloqué suite à une fontcion blouante, il ne revien pas au debut de sa boucle, ou à l'instruction de test, et ainsi, il ne se terminera pas même si l'évènement est envoyé.

Terminer proprement un thread devrait suivre cet alogorihtme:

Code:

---

1 2 3 4 5

appeller la méthode(procèdure) de terminison de thread de la classe(librairie). Attendre l'expiration d'un timeout. Si le thread n'est toujours pas terminé alors le tuer brutalement via TerminateThread (ou plus violent)

---

Bien sûr, dans ce cas toute ressources allouées dynamiquement par le thread dans le cas d'une terminaison violente resteront allouées.

C'est pour cette raison que j'évite au maximum d'allouer des ressources lourdes dans un thread, je préfère que l'appellant les alloue et passes un structure de pointeurs au thread via pArg.

Merci pour ses précisions.

Je viens d'adapter ma classe CMyDialog en fonction de la classe CWorkerThread.

CMyDialog possèd donc 2 handler privés : m_EndThread et m_WaitThread

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

BOOL CProcessDlg::OnInitDialog() { ... InitThread(); ... }   bool CProcessDlg::InitThread() { HANDLE m_EndThread = CreateEvent(0, TRUE, FALSE, 0); HANDLE m_WaitThread = CreateEvent(0, TRUE, FALSE, 0);   m_pThread = AfxBeginThread(ThreadFunc, this); if(!m_pThread) { // Impossible de créer le thread ! return false; } return true; }   UINT CProcessDlg::ThreadFunc(LPVOID pvParam) {   CProcessDlg *pThis=static_cast<CProcessDlg*>(pvParam); while(true) { if(WaitForSingleObject(pThis->m_EndThread, 0) == WAIT_OBJECT_0) { SetEvent(pThis->m_WaitThread); return 0; }   pThis->m_pProject->start();   } return 0; }   void CProcessDlg::OnCancel() { // declenche la fin du thread SetEvent(m_EndThread);   // attend que le thread soit terminé WaitForSingleObject(m_WaitThread, INFINITE);   // fermeture dans handles CloseHandle(m_EndThread); CloseHandle(m_WaitThread);   //CDialog::OnCancel(); }

---

Le fait de cliquer sur "Cancel" doit provoquer l'arrêt du Thread. Mais ca ne marche pas, il tourne en boucle...

Si quelqu'un pouvait m'expliquer... :triste:

re,
je comprends pas la:

Code:

---

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17

bool CProcessDlg::[b]InitThread()[/b] { //HANDLE m_EndThread = CreateEvent(0, TRUE, FALSE, 0); // HANDLE m_WaitThread = CreateEvent(0, TRUE, FALSE, 0);   m_EndThread = CreateEvent(0, TRUE, FALSE, 0); m_WaitThread = CreateEvent(0, TRUE, FALSE, 0);   m_pThread = AfxBeginThread(ThreadFunc, this); if(!m_pThread) { // Impossible de créer le thread ! return false; } return true; }

---

les variables m_EndThread ne doivent pas etre locales a la fonction initthread mais locale a la classe....
:D

J'suis trop bete. J'avais effectivement m_EndThread et m_WaitThread en variable privé de ma classe.
Mais par un copier-coller malheureux, dans InitThread j'en ai redéfinie deux nouvelles au lieu d'affecter celles existantes. :sm:

Et maintenant, ca marche !!! Merci !!!


Dans mon thread j'exécute une suite de fichier exe avec ShellExecute grace à la fonction start(). Quand je clique sur annuler, il faut attendre que tout les exe aient été exécuté pour que ca se termine...
Y a t'il un moyen simple pour interrompre la fonction "start();" dès que l'utilisateur clique sur annuler ?

C'est la modification que j'ai proposé dans la FAQ:
http://www.developpez.net/forums/vie...800489#1800489