TThread et multiprocesseur

Version imprimable

Salut à tous,

A chaque jour son petit sujet...

Je travail sur la création de thread afin de faire du "parallèle". Voici le petit thread de chronométrage que j'ai "créé" :

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
#ifndef chronometreH
#define chronometreH
//---------------------------------------------------------------------------
#include <Classes.hpp>
//---------------------------------------------------------------------------
class ThChrono : public TThread
{
private:
protected:
        void __fastcall Execute();
        void __fastcall AffMessage();
 
public:
        __fastcall ThChrono(bool CreateSuspended);
 
        LARGE_INTEGER  start;      //!< The start time of the chronometer
        LARGE_INTEGER  tic;
        LARGE_INTEGER  FQPF;
 
        bool           HRPCAvail;  //!< Is there an available HRPC
 
        AnsiString millit;
        double result;
};
//---------------------------------------------------------------------------
#endif

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
54
55
56
57
#include <vcl.h>
#pragma hdrstop
 
#include "chronometre.h"
#include "page_essai.h"
#pragma package(smart_init)
//---------------------------------------------------------------------------
//---------------------------------------------------------------------------
 
__fastcall ThChrono::ThChrono(bool CreateSuspended)
        : TThread(CreateSuspended)
{
}
//---------------------------------------------------------------------------
//---------------------------------------------------------------------------
void __fastcall ThChrono::Execute()
{
 
        HRPCAvail=QueryPerformanceCounter(&start); //memo du temps de start
        if (!HRPCAvail)   //si le compteur n'était pas disponible
        {
          start.LowPart = ::GetTickCount();   //basse resolution
          start.HighPart = 0;
        }
 
        while (!Terminated)
        {
           if (HRPCAvail) //si le compteur haute resolution était dispo
           {
             QueryPerformanceCounter(&tic); //recup du temps
 
             QueryPerformanceFrequency(&FQPF); //recup de la frequence
 
             //resultat en msec
             result=static_cast<double>(tic.QuadPart - start.QuadPart) * 1000
              /static_cast<double>(FQPF.QuadPart);
           }
           else //si le compteur n'était pas disponible
           {
             tic.LowPart = ::GetTickCount();
             tic.HighPart = 0;
 
             result = 0;
             //resultat
             result=tic.LowPart - start.LowPart;
 
           }
           millit = AnsiString(result);
           Synchronize(AffMessage);
        }
}
//---------------------------------------------------------------------------
//---------------------------------------------------------------------------
void __fastcall ThChrono::AffMessage()
{
       ecran_essai->Label1->Caption = millit;
}

Je met créé entre guillemet car j'ai énormément pompé sur le code trouvé dans ce poste

Ma question est de savoir s'il existe un moyen de s'assurer ou de forcer l'utilisation des différents cœurs du PC? Un coeur pour le process principal et un autre pour les threads.

Même si mon process n'est composé que de tâches durant plusieurs centième de seconde, que ce chrono est "riche" pour mon utilisation, je préfère assuré le process.

25/03/2011, 09h22
nirgal76

Tu as la fonction SetThreadAffinityMask qui permet de définir les coeurs que pourras utiliser ton thread

http://msdn.microsoft.com/en-us/libr...=vs.85%29.aspx

DWORD_PTR WINAPI SetThreadAffinityMask(
__in HANDLE hThread,
__in DWORD_PTR dwThreadAffinityMask
);

hThread : premier paramètre, l'ID de ton thread
dwThreadAffinityMask : le masque d'utilisation des cores. 1 bit par coeur. bit de poids faible pour le core n°1.
exemple :
pour n'utiliser que le core n°1, tu mets 0x1
pour n'utiliser que le core n°2, tu mets 0x2
pour n'utiliser que les core n°1 et 2, tu mets 0x3
pour n'utiliser que le core n°3, tu mets 0x4
pour n'utiliser que les core n°1 et 3, tu mets 0x5
pour n'utiliser que les core n°2 et 3, tu mets 0x6
pour n'utiliser que les core n°1, 2 et 3, tu mets 0x7
...
Attention, tu dois donner un pointer sur un dword contenant le masque, pas le dword lui même

DWORD mask=0x3;
SetThreadAffinityMask(threadID, &mask);

Super merci Nirgal76. Ça parait assez simple à utiliser.

Petites précisions :

Ta fonction s'utilise dans la definition du thread ou dans le code qui lance le thread ?

sur le ThreadID. Si je lance mon thread comme cela :

Code:

1
2
3
4
5
6
7
 
void __fastcall Tecran_essai::startClick(TObject *Sender)
{
 
        chrono = new ThChrono(false);
 
}

Quel est le threadID (handle) ?

//+++++++++++++++++++++++++++++++++++++++

Pour la suite c'est plus un problème d'utilisation du thread que je rencontre. Mon premier code fonctionne mais j'aimerai que le label récupérant le temps chrono ne soit pas écrit en dur dans le thread. J'aimerai donc pouvoir spécifié à la création du thread où il doit écrite la donnée lors de la synchronisation. Voici donc le code que j'ai fait :

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
#ifndef chronometreH
#define chronometreH
//---------------------------------------------------------------------------
#include <Classes.hpp>
//---------------------------------------------------------------------------
class ThChrono : public TThread
{
private:
protected:
        void __fastcall Execute();
        void __fastcall AffMessage();
 
public:
        __fastcall ThChrono(bool CreateSuspended,AnsiString *data);
        AnsiString *Thdata;
 
        LARGE_INTEGER  start;      //!< The start time of the chronometer
        LARGE_INTEGER  tic;
        LARGE_INTEGER  FQPF;
 
        bool           HRPCAvail;  //!< Is there an available HRPC
 
        AnsiString millit;
        double result;
};
//---------------------------------------------------------------------------
#endif

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
__fastcall ThChrono::ThChrono(bool CreateSuspended,AnsiString *data)
        : TThread(CreateSuspended)
{
        Thdata = data;
}
//---------------------------------------------------------------------------
//---------------------------------------------------------------------------
void __fastcall ThChrono::Execute()
{
 
        HRPCAvail=QueryPerformanceCounter(&start); //memo du temps de start
        if (!HRPCAvail)   //si le compteur n'était pas disponible
        {
          start.LowPart = ::GetTickCount();   //basse resolution
          start.HighPart = 0;
        }
 
        while (!Terminated)
        {
           if (HRPCAvail) //si le compteur haute resolution était dispo
           {
             QueryPerformanceCounter(&tic); //recup du temps
 
             QueryPerformanceFrequency(&FQPF); //recup de la frequence
 
             //resultat en msec
             result=static_cast<double>(tic.QuadPart - start.QuadPart) * 1000
              /static_cast<double>(FQPF.QuadPart);
           }
           else //si le compteur n'était pas disponible
           {
             tic.LowPart = ::GetTickCount();
             tic.HighPart = 0;
 
             result = 0;
             //resultat
             result=tic.LowPart - start.LowPart;
 
           }
           millit = AnsiString(result);
           Synchronize(AffMessage);
        }
}
//---------------------------------------------------------------------------
//---------------------------------------------------------------------------
void __fastcall ThChrono::AffMessage()
{
       *Thdata = millit;
}

Avec l'appel du thread :

Code:

1
2
3
4
5
 
void __fastcall Tecran_essai::startClick(TObject *Sender)
{
        chrono = new ThChrono(false,&(Label1->Caption));
}

Ça compile bien mais j'ai un bel access violation à l'exécution et c'est visiblement lors de l'exécution de la fonction du thread AffMessage().
Une idée sur le pourquoi du comment?

30/03/2011, 23h20
noahsaga

Un petit up car j'ai toujours mon problème. :(
31/03/2011, 08h17
nazgul66

Bonjour, tu passe quoi en paramètre à ton Thread ?
31/03/2011, 11h52
ShaiLeTroll

C'est surprenant que cela compile !
tu ne peux pas passer une propriété (Caption) en paramètre var (* ou &), cela contournerait les accesseurs défini par __property !
En Delphi, ça ne compilerait pas du tout ! le C++ se laisse berner !

le plus propre serait de définir un Evènement dans lequel tu fournis le nouveau libellé, lancer par Synchronize évidemment !

Citation:

Quel est le threadID (handle) ?

tu as une propriété Handle et ThreadID sur l'objet TThread, c'est cela que tu parles ?
31/03/2011, 14h19
nirgal76
Utilise la propriété Handle de TThread pour avoir le handle necessaire à setThreadAffinityMask.
La propriété ThreadId va retourner l'ID ce qui est différent :
Code de la VCL de TThread à ce sujet :
Code:

1 2 3 FHandle := Windows.GetCurrentThread; FThreadId := Windows.GetCurrentThreadId;
Donc dans ton thread tu utiliseras:
Code:

1 2 SetThreadAffinityMask(Handle,&mask);
ou si tu aime l'API
Code:

1 2 SetThreadAffinityMask(GetCurrentThread(),&mask);
Pour ton caption, passe plutot un pointeur sur le TLabel à ton constructeur
tu défini une donnée membre private de ton Thread :
Code:

1 2 3 private: TLabel* mLabel;
Ton constructeur
Code:

1 2 3 4 5 6 __fastcall ThChrono(bool CreateSuspended, TLabel* pLabel) { mLabel=pLabel; ... }
et dans un Synchronize tu fais
Code:

1 2 mLabel->Caption=....
Pour l'appel du thread:
Code:

1 2 3 4 5 void __fastcall Tecran_essai::startClick(TObject *Sender) { chrono = new ThChrono(false, Label1); }

Salut à tous et merci pour vos réponses.

Je viens d'essayer la méthode de Nirgal76. je pensais que l'utilisation de composants visuels comme un TLabel était impossible avec les thread car ils n'ont pas de "visuel".
La méthode marche pour un appel du thread mais dès que je veux en lancer 2 en simultané le programme "Freeze". En passant par le debugger, je peux voir que les 2 threads semblent s'exécuter mais sur le programme principal plus rien ne répond : action sur les boutons impossible, affichage des 2 labels chrono immobiles.
Pour ce qui est du ThreadAffinityMask, j'ai tout mis en commentaire car ça ne compile pas. :(

voici le code.

l'appel des 2 thread (les 2 chronos) :

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
void __fastcall Tecran_essai::start1Click(TObject *Sender)
{
        chrono[1] = new ThChrono(false,Label1);
}
//---------------------------------------------------------------------------
 
void __fastcall Tecran_essai::stop1Click(TObject *Sender)
{
        chrono[1]->Terminate();
}
//---------------------------------------------------------------------------
 
 
void __fastcall Tecran_essai::start2Click(TObject *Sender)
{
        chrono[2] = new ThChrono(false,Label2);
}
//---------------------------------------------------------------------------
 
void __fastcall Tecran_essai::stop2Click(TObject *Sender)
{
        chrono[2]->Terminate();
}
//---------------------------------------------------------------------------

Le cpp du chrono :

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
54
55
56
57
58
59
60
61
62
63
64
#include <vcl.h>
#pragma hdrstop
 
#include "chronometre.h"
#include "page_essai.h"
#pragma package(smart_init)
//---------------------------------------------------------------------------
//---------------------------------------------------------------------------
 
__fastcall ThChrono::ThChrono(bool CreateSuspended,TLabel* pLabel)
        : TThread(CreateSuspended)
{
        mLabel=pLabel;
 
        //DWORD mask=0x3;
 
        //DWORD STAM;
        //STAM = SetThreadAffinityMask(Handle, &mask);
}
//---------------------------------------------------------------------------
//---------------------------------------------------------------------------
void __fastcall ThChrono::Execute()
{
 
        HRPCAvail=QueryPerformanceCounter(&start); //memo du temps de start
        if (!HRPCAvail)   //si le compteur n'était pas disponible
        {
          start.LowPart = ::GetTickCount();   //basse resolution
          start.HighPart = 0;
        }
 
        while (!Terminated)
        {
           if (HRPCAvail) //si le compteur haute resolution était dispo
           {
             QueryPerformanceCounter(&tic); //recup du temps
 
             QueryPerformanceFrequency(&FQPF); //recup de la frequence
 
             //resultat en msec
             result=static_cast<double>(tic.QuadPart - start.QuadPart) * 1000
              /static_cast<double>(FQPF.QuadPart);
           }
           else //si le compteur n'était pas disponible
           {
             tic.LowPart = ::GetTickCount();
             tic.HighPart = 0;
 
             result = 0;
             //resultat
             result=tic.LowPart - start.LowPart;
 
           }
           millit = AnsiString(result);
           Synchronize(AffMessage);
           //Thdata = &AnsiString(result);
        }
}
//---------------------------------------------------------------------------
//---------------------------------------------------------------------------
void __fastcall ThChrono::AffMessage()
{
       mLabel->Caption= millit ;
}

et le .h :

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
#ifndef chronometreH
#define chronometreH
//---------------------------------------------------------------------------
#include <Classes.hpp>
//---------------------------------------------------------------------------
class ThChrono : public TThread
{
private:
        TLabel* mLabel;
protected:
        void __fastcall Execute();
        void __fastcall AffMessage();
 
public:
        __fastcall ThChrono(bool CreateSuspended,TLabel* pLabel);
        AnsiString *Thdata;
 
        LARGE_INTEGER  start;      //!< The start time of the chronometer
        LARGE_INTEGER  tic;
        LARGE_INTEGER  FQPF;
 
        bool           HRPCAvail;  //!< Is there an available HRPC
 
        AnsiString millit;
        double result;
};
//---------------------------------------------------------------------------
#endif

31/03/2011, 17h38
nirgal76
Oui bon, me suis arraché ;) faut passer la variable "mask", pas sa référence "&mask".
Code:

1 2 3 4 5 DWORD mask=0x3; DWORD STAM; STAM = SetThreadAffinityMask(Handle, mask);
Pour le reste, pour l'instant, je vois déjà que tes thread tournent sans temps mort.
Dans ton thread, dans le bloc while (!terminated), après le synchronize, insere un Sleep pour donner du temps cpu aux autres thread (y compris le thread principal.
"Sleep(0);" peut suffire, sinon "Sleep(1);", enfin, à toi de voir le temps qu'il faut mettre en testant.
31/03/2011, 17h52
noahsaga

Bravo pour le sleep(1); c'est du bon sens... J'avais déjà eu ce type de problème avec des boucles while sous LabView sur du FPGA. Si tu ne donne pas de temps pour souffler un peu le reste du process ne peut plus s'exécuter. Cela marche au poil.

Par contre la fonction SetThreadAffinityMask ne compile toujours pas car il me dit que Handle (propriété du thread) est un unsigned int et qu'il attends un void...
01/04/2011, 09h28
nirgal76
Alors fait le avec
Code:

1 2 SetThreadAffinityMask(::GetCurrentThread(),mask);
ça au moins c'est sur que ça marche (ici ça compile en BCB 2010)
04/04/2011, 10h49
noahsaga

ok ça compile!

Merci
14/04/2011, 22h35
INFOset

un Thread qui lance un autre thread

slt à toutes et à tous,
Je suis entrain de programmer une application qui doit exécuter 2 threads en même temps (avec c++builder). mais le premier thread doit faire une itération ensuite il lance le deuxième thread.

pour cela dans le programme principale, j'utilise la fonction Resume(); pour lancer le premier thread . et dans le corps du premier thread j'utilise aussi Resume(); pour lancer le deuxieme.

Néanmoins, lorsque je lance mon application, je m'aperçois que le thread 1 fonctionne bien mais que le 2 n'est pas activé. Il s'active uniquement lorsque le 1 se termine.
donc pas de parallélisme , je ne sais pas est ce que je doit ajouter quelque chose:calim2: