Discussion :

[japle]

Bonjour à tous,

J'ai un petit problème quant à l'utilisation des threads. Mon code de base et de ce type:

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
 
void ObjetPrincipal::maFonction()
{
    for(int i=0; i<10; i++)
    {
        tableauObjets[i]->maMethode(); //On a :  vector< Objet* > tableauObjets;
    }
}
 
void ObjetPrincipal::bouclePrincipal()
{
    for(int k=0;k<5000;k++)
    {
	//....
 
	maFonction();
 
	//...
    }
 
}

Ce que je souhaiterais c'est avoir un thread par tableauObjets[i] pour exécuter maMethode(). J'arrive à réaliser cela grâce à ce code:

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

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
 
void* start_thread(void* arg) 
{
     static_cast<Objet*>(arg)->maMethode();
     pthread_exit(NULL);
}
 
void ObjetPrincipal::maFonction()
{
     int i;
     pthread_t thread[10];
 
     for(i = 0 ; i < 10 ; i++)
	  pthread_create (&thread[i], NULL, start_thread, tableauObjets[i]);
 
     for(i = 0 ; i < 10 ; i++)
          pthread_join (thread[i], NULL);
 
}
 
void ObjetPrincipal::bouclePrincipal()
{
    for(int k=0;k<5000;k++)
    {
	//....
 
        maFonction();
 
	//...
    }

Ce code marche mais est plus long que si je n’utilisais pas de threads (j'ai un processeur double coeur). Je pense que cela est dû au fait que je recréé de nouveau threads à chaque fois. J'ai essayé de les réutiliser mais je n'y arrive pas, comment faut-il faire?

Merci d'avance pour votre aide.

[gerald3d]

Je ne suis pas un grand spécialiste des threads mais le problème semble venir de l'attente de fin pour chaque thread. Donc dans la deuxième boucle.

Si tu es forcé de t'assurer que le traitement du tableau est complet avant de poursuivre, peut être que tu peux utiliser une variable partagée que chaque thread incrémente. Il te suffit alors de faire une boucle d'attente dans laquelle tu compares cette variable avec le nombre d'élément du tableau. Une fois les deux valeurs identiques, tu sors de la boucle pour poursuivre.

Cette méthode permet à tous les threads de s’exécuter sans attente. En contre partie on a tout de même une boucle d'attente générale. Et qui est bloquante de surcroît. A toi de voir...

[japle]

Je ne comprend pas du tout ce qui ce passe. J'ai essayer avec un seul Thread. Voila mon code:

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

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
 
pthread_cond_t condition= PTHREAD_COND_INITIALIZER;
pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER;
int compteur=0;
 
void* start_thread(void* arg) 
{
    while(1)
    {
        pthread_mutex_lock(&mutex); 
	pthread_cond_wait (&condition, &mutex); 
	pthread_mutex_unlock(&mutex);
 
        static_cast<Objet*>(arg)->maMethode();
        compteur++;
    }
    pthread_exit(NULL);
}
 
void ObjetPrincipal::bouclePrincipal()
{
    pthread_create(&monThread, NULL, start_thread, tableauObjets[0]);
 
    for(int k=0;k<5000;k++)
    {
	//....
 
        pthread_mutex_lock (&mutex);
	pthread_cond_signal (&condition);
	pthread_mutex_unlock (&mutex);
 
	while(compteur!=1){}
	compteur=0;
 
	//...
    }
    pthread_join (monThread, NULL);
}

Mais cela ne marche pas.

[gerald3d]

Tu modifies "compteur" dans le thread alors qu'en même temps tu compares sa valeur dans le main. "compteur" doit être inclus dans le mutex.
Ensuite comment sors-tu de la boucle while(1)?

[japle]

Merci, avec le mutex sa marche. Bon par contre, le code est plus lent que précédemment, je crois que je vais donc abandonner le multi-threading.