Redémarrer un CWinThread

Version imprimable

10/04/2007, 18h07
shenron666

Redémarrer un CWinThread

Bonjour,

J'ai multi-threadé :king: une fonction assez lourde pour accélérer un peu le traitement de mon application.

Ca fonctionne, je peux paramétrer le nombre de threads de 1 à n :yaisse2:

Mainenant, dans la boucle de gestion de mes threads, je redémarre un thread de la façon suivante (qui est la même que la création ormis le delete) :
- destruction du thread avec delete
- création d'un nouveau thread avec AfxBeginThread
- modification du membre du thread m_bAutoDelete à false
- ResumeThread

Y a t-il un moyen plus simple et surtout moins couteux en temps machine pour redémarrer mon thread ?

je précise que la fonction threadée fait un traitement et retourne une valeur style 0 ou 1
peut-etre faut-il que je la modifie elle aussi ?
10/04/2007, 18h19
farscape

salut,
tu peux le suspendre ...

Citation:

CWinThread::SuspendThread

et le relancer par ResumeThread().
:D

j'ai essayé le ResumeThread tout seul sans succès, c'est ce qui m'a ammené à faire un delete suivi d'un nouveau AfxBeginthread

en gros, j'ai une boucle qui gère mes threads :

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
	INT_PTR nIndexThread;
	while(arThreads.GetCount() > 0)
	{
		// on rend la main au système
		Sleep(1);
 
		// puis on parcours les threads du dernier au premier
		nIndexThread = arThreads.GetUpperBound();
		for(; nIndexThread >= 0; nIndexThread--)
		{
			// récupération de l'état du thread
			GetExitCodeThread(arThreads[nIndexThread]->m_hThread, &nResult);
			// si le thread est actif
			if(nResult == STILL_ACTIVE)
				continue; // on passe au suivant
			// si le thread n'est plus actif
			// on regarde s'il y a encore des questions à traiter
			if(nIndexQues < arQuestions.GetCount())
			{
				// on paramètre la nouvelle question à gérer
				arParams[nIndexThread]->pQuesQuestion = arQuestions[nIndexQues++];
				// et on relance le thread
				delete arThreads[nIndexThread];
				arThreads[nIndexThread] = AfxBeginThread(CAFF_FileSDic::MatchQuestionThread, arParams[nIndexThread], THREAD_PRIORITY_NORMAL, 0, CREATE_SUSPENDED);
				arThreads[nIndexThread]->m_bAutoDelete = false;
				arThreads[nIndexThread]->ResumeThread();
			}
			else // plus de questions à traiter
			{ // suppression du thread et de ses params
				delete arThreads[nIndexThread];
				arThreads.RemoveAt(nIndexThread);
				delete arParams[nIndexThread];
				arParams.RemoveAt(nIndexThread);
			}
		}
	};

comme la fonction threadée est terminée par un return, il faut peut-etre que je commence par là non ?

je sais que c'est pas le top comme gestion de threads mais je commence à m'y mettre
si vous avez des conseils je suis preneur ;)

12/04/2007, 13h43
ZaaN

quand tu parle de redemarré un de tes thread, tu veux dire le faire executer a nouveau tout son code et non reprendre l'execution là ou elle était suspendue ( s il elle l'est)...

dans ce cas je te conseille :

faire qu il se relance avec une boucle
OU
faire que ton thread se tue tout seul (soritir de la boucle et m_bAutodelete=true)

Tout ca dans le code du thread bien sur...

mais si ton thread etait suspendu, ResumeThread est effectivement la meileure solution