Multithreading en C

Version imprimable

10/07/2007, 10h50
chti_juanito

Multithreading en C
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:

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:

1 2 3 4 for(i = 0; i < nb_elem; i++) { (void)pthread_join(tab_thread[i], &ret); }
voilou si vous pouvez m'aider... ;)
10/07/2007, 11h16
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é).
10/07/2007, 11h33
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...
10/07/2007, 11h53
psyphi

Désolé j'avais lu ton message trop vite :oops:
essaye de jouer avec les 'join' pour voir ce qu'il passe.
10/07/2007, 11h54
chti_juanito

ok apparemment ça fonctionne...

Salut, moi aussi je fait exactement la même chose, mais ça marche à merveille. Voici une partie de mon code

Code:

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...