Discussion :

[michel42]

Bonsoir,

j'ai fait un script dans lequel je lance différents logiciels à la chaîne (les inputs entre les logiciels ne sont pas les mêmes). Ma question est simple, j'aimerai savoir comment les lancer en parallèle.

Pour le moment je fait quelque chose comme ça :

Code :

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

1
2
3
os.system("Logiciel_1 input1")
 
os.system("Logiciel2 input2")

Le problème c'est que dans cette configuration je dois attendre la fin du 1er traitement pour commencer le second, d'où une perte de temps.

Merci à vous

[ZZelle]

Tu peux regarder du côté de threading ou multiprocessing.
os.system est déprécié, il est préférable d'utiliser subprocess.call/checkcall.

Usage type de threading (c'est similaire pour multiprocessing):

Code :

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

1
2
3
4
5
6
7
8
9
10
11
12
 
#On définit les threads
t0 = threading.Thread(target=subproces.call, ['ls', '/'])
t1 = threading.Thread(target=subproces.call, ['ls', '/tmp'])
 
# On démarre les threads (les appels à subprocess sont concurrents)
t0.start()
t1.start()
 
# # On attend la "fin" des threads
t0.join()
t1.join()

[emmanuel_dumas]

Bonjour

Je pense que la bonne réponse se trouve dans le package subprocess (http://docs.python.org/py3k/library/subprocess.html) et la commande Popen.

Les premières utilisations paraissent un peu barbare, cependant à l'usage on réalise qu'on peut faire beaucoup de chose de manière propre et efficace.

Cordialement
Emmanuel

[michel42]

Merci beaucoup pour vos réponses je vais étudier tout ça

[Montag]

Tu peux regarder du côté de threading ou multiprocessing.
os.system est déprécié, il est préférable d'utiliser subprocess.call/checkcall.

Usage type de threading (c'est similaire pour multiprocessing):

Code :

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

1
2
3
4
5
6
7
8
9
10
11
12
 
#On définit les threads
t0 = threading.Thread(target=subproces.call, ['ls', '/'])
t1 = threading.Thread(target=subproces.call, ['ls', '/tmp'])
 
# On démarre les threads (les appels à subprocess sont concurrents)
t0.start()
t1.start()
 
# # On attend la "fin" des threads
t0.join()
t1.join()

Utiliser des threads n'a aucun intérêt ici. Il suffit juste d'utiliser la classe Popen du module subprocess :

Code :

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

1
2
3
4
5
6
7
from subprocess import Popen
 
p0 = Popen(['sleep', '10'])
p1 = Popen(['sleep', '10'])
 
p0.wait()
p1.wait()

[michel42]

Utiliser des threads n'a aucun intérêt ici. Il suffit juste d'utiliser la classe Popen du module subprocess :

Code :

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

1
2
3
4
5
6
7
from subprocess import Popen
 
p0 = Popen(['sleep', '10'])
p1 = Popen(['sleep', '10'])
 
p0.wait()
p1.wait()

Bonjour,

je ne suis pas sur de comprendre ce morceau de code, lorsque l'on utilise wait() cela signifie que les processus "s'attendent" avant de continuer ?

J'ai tenté d'adapter ce code à mon problème comme cela :

Code :

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

1
2
p0 = Popen(['./logiciel input1.txt input2.txt'])
p1 = Popen(['./logiciel2 input1.txt input2txt'])

je vais travailler la syntaxe ce n'est pas encore ça

[mont29]

Avec Popen, chaque élément de la "ligne de commande" doit être un item de la liste –*donc plutôt quelque chose comme ça*:

Code :

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

1
2
p0 = Popen(['./logiciel', '-i', 'input1.txt', '-o', 'input2.txt'])
p1 = Popen(['./logiciel2', 'input1.txt', 'input2txt'])

(en fait, à chaque fois qu’il y a un espace non protégé, on ajoute un élément à la liste des paramètres).


Pour ce qui est de wait(), le premier appel p0.wait() va bloquer jusqu’à ce que p0 soit terminé. Puis p1.wait() va bloquer jusqu’à ce que p1 soit terminé –*si p1 a fini avant p0, alors p1.wait() retourne immédiatement, et le résultat est toujours le même*: après ces deux lignes, on est sûr que les deux process ont fini (d’une manière ou d’une autre).