Lancer des logiciels en parallèle

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:

---

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

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:

---

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()

---

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

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

Citation:

---

Envoyé par 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:

---

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:

---

1 2 3 4 5 6 7

from subprocess import Popen   p0 = Popen(['sleep', '10']) p1 = Popen(['sleep', '10'])   p0.wait() p1.wait()

---

Citation:

---

Envoyé par Montag

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

Code:

---

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:

---

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

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:

---

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