Discussion :

[manelhaj]

Bonjour,
voilà, je suis débutante dans le multithreading. j'explique mon problème: j'ai une fonction qui est exécuté avec deux threads selon le code suivant:

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
 
fonction (a)
{
 .....
 
}
 
main()
{
  funcParams params;
  params.a = rand(1,3);
 
_beginthread(MaFonction,0,&params);
}
 
void MaFonction(void* p)
{
  funcParams *params = static_cast<funcParams>(p);
  f(params->a);
}

Lorsque les deux threads sont asynchrones, le programme fonctionne bien mais lorsque les threads sont sychrones, l'une des threads s’exécute avec le paramètre a de l'autre thread. Dans ce cas on a deux threads identique alors que ces threads doivent être différentes selon leur paramètre a

Je serai reconnaissante pour toute information utile pour résoudre mon problème.

[Médinoc]

Passe à ton thread un pointeur vers une nouvelle structure allouée avec malloc/new;

[manelhaj]

Merci pour votre réponse en faite même en ajoutant une allocation dynamique de la structure. Je trouve le même résultat et même problème

[Médinoc]

Passerais-tu le même pointeur aux deux threads? Il ne faut pas le faire si tu veux qu'ils aient des données séparées.

[manelhaj]

Bonjour en faite je suis entrain de modifier le pointeur puisque lorsque je lance les deux threads asynchrone( l'une commence avant l'autre par une seconde par exemple) j’obtiens une exécution correcte mais lorsque ils sont synchrone et ils débutent en même instant j'obtiens ce problème.

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
 
struct thread_param{
	antnet *ser;
	ant_pkt* ant;
	};
typedef std::vector<struct thread_param> param_matrix;
....
static DWORD WINAPI ThreadLauncher(void *p)
{
struct thread_param *Obj = reinterpret_cast<struct thread_param*>(p);
return s->forward_ant(Obj->ant);
}
....
int main() 
{ 
		for(int j=0; j<iRandom;j++)
			{
				if(a<ant_max)
				{
 
				ant_pkt *Myant = new ant_pkt(src0,(G.dest_G)->GetNode(), s->cur_t , a);
 
 
					struct thread_param p;
					p.ser = s;
					p.ant = Myant;
					tempss.push_back(p);
					hThreadArray[a] = CreateThread(NULL, 0,&ThreadLauncher, &p,0,&dwThreadIdArray[a]);
					if ( hThreadArray[a] == NULL )
					{
 
					}
 
					a++;
				}
			}
....
}

[Médinoc]

s est une variable globale?
Partagée entre tous les threads?