Discussion :

[chti_juanito]

bonjour @ tous...

je veux faire du multithreading en C. Pour l'instant j'ai déjà créé des threads, mais lorsqu'un démarre, le suivant attends que le précédent soit exécuté pour démarré... moi je veux que les threads se lancent en même tps...

j'ai créé un tableau de thread, puis au moment venu, dans une boucle for :

Code :

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

1
2
3
4
5
if(pthread_create(&tab_thread[i], NULL, start_script_process, (void*)serverList[i]) < 0)
{
       fprintf(stderr, "pthread_create error\n");
       exit(1);
}

dans une autre boucle for à la suite :

Code :

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

1
2
3
4
for(i = 0; i < nb_elem; i++)
{
	(void)pthread_join(tab_thread[i], &ret);
}

voilou si vous pouvez m'aider...

[valefor]

Je ne pense pas que tu puisses lancer plusieurs threads rigoureusement au même moment.

Par contre au tout début de chaque thread tu peux mettre un point de synchro (style un pthread_cond_wait par exemple, mais le man pthread te donnera des infos plus précises).
Une fois tes thread lancés et tous dans les starting blocs, tu diffuses le signal (pthread_cond_broadcast, mais la encore un petit tour par le man est recommandé).

[chti_juanito]

oui je sais tout ça, mais si j'enlève ma boucle effectuant les join, ERROR apparait lors de l'exécution...

et j'ai du code suffisamment important, puisque je lance un script qui dure 10 secondes pour un thread et un de 30 secondes pour un autre...

[psyphi]

Désolé j'avais lu ton message trop vite
essaye de jouer avec les 'join' pour voir ce qu'il passe.

[chti_juanito]

ok apparemment ça fonctionne...

[salseropom]

Salut, moi aussi je fait exactement la même chose, mais ça marche à merveille. Voici une partie de 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
 
while(tout<=tfin)
  {
                      /*****  Chemistry  *****/    
 
    for(i=0;i<nbproc;++i)
    {
      integ[i].t=t[i]; integ[i].tout=ttout[i];
      ret=pthread_create(&task[i], NULL, Integration, &integ[i]);
      if(ret!=0)
      {
        fprintf(stderr,"%s %d : impossible to create the thread	%u\n",__FILE__,__LINE__,i);
	exit(EXIT_FAILURE);
      }
 
      t[i]=tout;
    } /* end for(i=0;i<nbproc;++i) */
 
    for(i=0;i<nbproc;++i) pthread_join(task[i], NULL);

j'ai bien une boucle for qui lance les threads et une boucle for qui fait les join. C'est bizarre que ton code ne marche pas bien...