Perl et sémaphores

Bonjour !!

Voila je tente de faire executer 4 processus en parallèle, le tout à l'aide de sémaphores, pour gérer le nombre de processus en même temps.

Pour etre plus clair, j'aimerais qu'il n'y ait que 2 processus qui s'exécutent en même temps.

J'ai donc créé un ensemble de sémaphores, et lancer l'exécution de 4 scripts via une table AT... Le code étant souvent plus explicite :

Code:

---

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18

#/usr/local/bin/perl   $IPC_KEY = 1234; $id = semget(1234, 2 , IPC_CREAT);     $action = "/home/mbe/test/threads/bonjour.pl 1\n"; $action .= "/home/mbe/test/threads/bonjour.pl 2\n"; $action .= "/home/mbe/test/threads/bonjour.pl 3\n"; $action .= "/home/mbe/test/threads/bonjour.pl 4\n";   $fich_crontab = "/home/mbe/test/threads/crontab";   open (FIC,">$fich_crontab")|| die "Probleme d'ouverture"; print FIC ($action."\n") || die "Probleme d'ecriture"; close FIC;   system "at now < $fich_crontab > /dev/null";

---

Petite description rapide du script bonjour.pl :
Il se contente d'écrire en boucle pendant un peu de temps dans un fichier, et rend la main :

Code:

---

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

#!/usr/local/bin/perl   use strict;   my $param = $ARGV[0];   my $i = 0; my $cptSec = 0;   my ($sec, $min, $heure, $jourM, $mois, $annee) = localtime(time); open (FIC, ">>/home/mbe/test/threads/rapports/test_".$param.".txt"); print FIC "commencé a $heure:$min:$sec \n";   my $sem_op_P = pack("s!3", 0, -1, 0); my $sem_op_V = pack("s!3", 0, 1, 0);   # Recup de l'ensemble de semaphores #my $id = semget(1234, 0, 0);   # On demande la ressource semop(1234, $sem_op_P);   while ($i < 10) {   ($sec, $min, $heure, $jourM, $mois, $annee) = localtime(time); print FIC "J'ai ecrit a $heure:$min:$sec \n"; $cptSec += 10*$i; sleep (5); $i++; }   ($sec, $min, $heure, $jourM, $mois, $annee) = localtime(time); print FIC "terminé a $heure:$min:$sec \n"; close FIC;   # On libère la ressource semop(1234, $sem_op_V);

---

Voilà mon problème : mes processus/scripts s'exécutent l'un après l'autre. Et dans mes fichiers, l'heure de fin du fichier précédent "terminé à" correspond à l'heure du début du script en cours "commencé à", ce qui prouve bien l'exécution l'un après l'autre.



D'où ma question : pourquoi ? :mrgreen: :mrgreen:

Est ce que ca vient en fait de la table AT qui les exécutent chacun leur tour ? Ou est ce que ca vient en fait des mes semaphores qui sont mal gérés ?

Merci beaucoup d'avance !

pourquoi n'utilise tu pas la semantique threads finalement?
Il y a tout ce qu'il faut dedans pour gerer correctement ce genre de probleme

Citation:

---

Envoyé par pospos

pourquoi n'utilise tu pas la semantique threads finalement?
Il y a tout ce qu'il faut dedans pour gerer correctement ce genre de probleme

---

Bah au final il s'est avéré que la mise en places de sémaphores est plus simple à mettre en place, et que les threads ne nous avancerait pas à grand chose, étant donné le nombre à lancer.

Et y a aussi le fait que la hierarchie m'a plus conseillé de gérer les semaphores... :roll: :roll: :roll:

Eyh !!

Bon j'ai résolu quelques problèmes (entre autre un use IPC::SysV qw(IPC_CREAT)) pour utiliser IPC_CREAT... :P :P

MAIS, réside un problème.

Je n'arrive pas à trouver la syntaxe du dernier argument à passer à semctl, que j'ai enfin réussi à comprendre...

Voila ce que j'ai pr l'instant :

Code:

---

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17

use IPC::SysV qw(IPC_CREAT);   $IPC_KEY = 1235; $id = semget($IPC_KEY, 1, IPC_CREAT | 0666); die if !defined($id);   print "Identifiant gp de semaphores -> $id \n";   my $args = pack("s!",(2)); my $res = semctl($id, 0, SETVAL, $args); print "-> $res \n";   for (my $iNumProc = 0; $iNumProc < 4; $iNumProc++) { my $Cmde = "/home/mbe/test/threads/bonjour.pl $iNumProc &";   system($Cmde); }

---

En clair je n'ai qu'un semaphore, et je veux l'initialiser à 2.

Please !!!

:cry: :cry: :cry:


PS : petit détail > la fonction semctl me renvoie la chaine "0 but true", ce qui signifie qu'il n'y aurait pas d'erreur :? :?

snif personne ? :cry: :cry: