Affichage de thread et concurrence des données

Version imprimable

11/07/2012, 09h10
atum25

Affichage de thread et concurrence des données

Bonjour,

Voila je cherche a crée un objet dans un nouveau thread, cette objet contient des méthodes, qui relèvent des informations d'un poste de travail.
JE cherche ensuite à afficher ces données dans un mémo.
Mais comme j'ai environ 100 threads, lorsqu'il arrive a la méthodes affiche(), il mélange les informations, ou alors affiche une parti d'un, puis un autre puis la fin du 1ere.

Je voudrais pouvoir le forcer à exécuter la fonction affiche d'un seul coup afin de n'afficher que les informations correspondantes a une seul machine.
11/07/2012, 11h56
cob59

Utilise un mutex pour restreindre à 1 seul thread à la fois les appels à affiche().
Si affiche() est une méthode, tu ajoutes un mutex dans tes attributs de classe et tu le verrouilles le temps de l'appel à affiche(). Sinon, même principe avec une variable globale que tu verrouilles au début de ta fonction.

Merci de ta reponse,
C'est ce que j'éssai de fair, mais cela ne fonctionne pas correctement (surement me suis-je tromper dans la mise en place du mutex.)

dans mon constructeur de l'objet j'ai placer :

Code:

1
2
3
4
5
6
7
8
9
10
11
12
 ghMutex = CreateMutex(
        NULL,              // default security attributes
        FALSE,             // initially not owned
        NULL);             // unnamed mutex
 
    if (ghMutex == NULL)
    {
        //cout<<"CreateMutex error: %d\n", GetLastError();
        Form1->Memo1->Lines->Add("mutex error");
        //return 1;
    }
    Affiche();

puis dans la fonction affiche :

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
 
       DWORD dwCount=0, dwWaitResult; 
       AnsiString Info;
       AnsiString Ip,Mac,Nom;
       switch (dwWaitResult)
       {
           // The thread got ownership of the mutex
           case WAIT_OBJECT_0:
               __try {
                          Ip = CAddIp;
                          Mac = CAddMac;
                          Nom = CNomNetBios;
                          Info = Nom + "   " + Ip + "   " + Mac ;
                          Form1->Memo1->Lines->Add(Info);
                }
 
                __finally {
                    // Release ownership of the mutex object
                    if (! ReleaseMutex(ghMutex)) 
                    { 
                        // Handle error.
                       // Form1->Memo1->Lines->Add("handle error");
                    } 
                } 
                break; 
 
            // The thread got ownership of an abandoned mutex
            // The database is in an indeterminate state
            case WAIT_ABANDONED: 
                Form1->Memo1->Lines->Add("erreur");
          }

11/07/2012, 16h19
cob59

A mon avis tu as copié-collé un code sans trop réfléchir.
Tu crées un mutex ghMutex mais tu ne le verrouilles pas au début de affiche()
Sauf erreur, je crois qu'il faudrait un WaitForSingleObject().

1 pièce(s) jointe(s)

Effectivement, je n'avais pas compris cela :/
Code:

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 void PosteDeTravail::Affiche() { AnsiString Info; AnsiString Ip,Mac,Nom; WaitForSingleObject(g_hMutex,INFINITE) ; __try { Ip = CAddIp; Mac = CAddMac; Nom = CNomNetBios; Info = Nom + " " + Ip + " " + Mac ; Form1->Memo1->Lines->Add(Info); } __finally { ReleaseMutex(g_hMutex); } }
J'ai donc fait un WaitSingleForObjet, mais cela ne fonctionne toujours pas mieu .Je joint une copie d'ecran de ce que j'obtiens,
Je devrais avoir sur chaque ligne "Nom + Addresse ip + Adresse MAc"

exemple : Poste_CTRL 192.168.2.8 00:11:29...
Pour chaque poste qui repond au ping

12/07/2012, 10h23
cob59
Est-ce que chaque thread possède une instance de PosteDeTravail ?
Si oui, ça signifie que tu as N instances de PosteDeTravail, qui gèrent N mutex vers 1 ressource unique (ton logger/afficheur), donc tes mutex en l'état ne servent à rien. Essaie plutôt d'allouer un mutex en static dans Affiche() :
Code:

1 2 3 4 5 6 7 8 9 void Affiche() { static HANDLE ghMutex = CreateMutex(NULL, FALSE, NULL); WaitForSingleObject(ghMutex, INFINITE) ; ... }
12/07/2012, 10h37
atum25

Oui c'est exactement sa.

JE comprend pas ce que cela change de le declarer en static, en faisant comme sa n'aurais-je pas un mutex par thread ?
12/07/2012, 10h42
cob59

En déclarant en static, ghMutex sera un attribut de classe, au lieu d'un attribut d'objet (cf FAQ). Il sera donc unique, comme la ressource qu'il est censé protéger.

1 pièce(s) jointe(s)

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
void PosteDeTravail::Affiche()
{
       AnsiString Info;
       AnsiString Ip,Mac,Nom;
 
       static HANDLE ghMutex = CreateMutex(NULL, FALSE, NULL);
        WaitForSingleObject(ghMutex, INFINITE) ;
 
      // WaitForSingleObject(g_hMutex,INFINITE) ;
       __try
        {
           //Ip = CAddIp;
           //Mac = CAddMac;
           //Nom = CNomNetBios;
           //Info = Nom + "   " + Ip + "   " + Mac ;
           //Form1->Memo1->Lines->Add(Info);
           Form1->Memo1->Lines->Add(CNomNetBios);
           Form1->Memo1->Lines->Add(CAddMac);
           Form1->Memo1->Lines->Add(CAddIp);
        }
       __finally
        {
           ReleaseMutex(ghMutex);
        }
}

Voila j'ai fais comme tu ma indiquer, mais cela ne fonctionne toujours pas, c'est toujours le bordezl lors de l'affichange

je joint une copie d'ecran

12/07/2012, 11h11
cob59

Tu as bien supprimé le ghMutex de tes attributs ?
12/07/2012, 11h15
atum25

Comment ca ? est ce que je dois ajouter dans mon objet le handle ghMutex dans mes attributs privé ?
12/07/2012, 11h25
cob59

Non, l'enlever justement.
De même que l'init via CreateMutex dans le constructeur.
12/07/2012, 11h27
atum25

Oui j'avais tout oter, je pense que cela fonctionne mais je dois avoir un problème au niveau du nom netbios, car je récupère le bon , puis ensuite il est modifier( je ne sais pas ou ni comment ) en morceau d'adresse ip ou d'addresse MAc