Discussion :

[Aure7780]

Bonjour,

Je fais une application qui a besoin de lancer X threads et d'attendre qu'ils aient tous finis avant d'en relancer d'autres. Mais je ne vois pas comment faire car la méthode ->join() bloque 1 thread mais pas plusieurs en même temps...

Voici mon bout de 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
my $LEVEL = $MATRIX->{LEVEL} + 1;
 
while ($LEVEL >= 0)
{
	$CPT = 0;
	while ($CPT <= $MATRIX->{LEVEL} + 1)
	{
		my $thr = threads->new(sub {
			print "Thread start\n";
			process($MATRIX->{$CPT});
			$MATRIX->{$CPT}->{STARTED} = 1;
			print "Thread end\n";
		});
		$CPT+=1;
	}
	# attendre ici que tous les threads lancé dans le while d'avant soient finis
	$LEVEL-=1;
}

Comment faire ça ?

[Philou67430]

Sauve tous tes threads dans ton tableau et join les dans une boucle :

Code :

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

$_->join() foreach @thr;

Si tu veux joiner les threads "au fur et à mesure", tu peux vérifier qu'ils sont joinable avant :

Code :

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

$_->join() foreach grep $_->is_joinable(), @thr;

[Aure7780]

Merci c'est exactement ce qu'il me fallait !

J'avais pensé à un tableau de référence de thread et appeler chaque join() mais je pensais que le join serait bloquant... mais comme on lance le thread avant pas de problème.

En revanche je n'arrive pas à utiliser la version avec is_joinable(), j'ai le message d'erreur suivant :
Can't locate auto/threads/is_joinable.al in @INC (...)

Cette fonction fait elle partie du core de perl (5.8.8) (car rien n'est indiqué dans la doc perl) ?

[djibril]

Tu peux toujours mettre à jour le module threads.

Code :

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

ppm install threads -f

[Aure7780]

Je ne peux pas, je ne dois pas ! (c'est de la prod)