Je pense que vous pouvez créer un processus enfant en utilisant le module subprocess, mais vous voudrez peut-être faire quelque chose comme surveiller le journal de cela, alors prenez note.
Le nombre est émis en standard toutes les 0,5 seconde.
child.py
import time
import sys
i = 0
while True:
print i
sys.stdout.flush()
i += 1
time.sleep(0.5)
Le but est de faire flush () et d'expulser les données accumulées dans le tampon.
Chaque fois qu'un enfant sort, il sera sorti.
parent.py
import subprocess
proc = subprocess.Popen(['python','child.py'],stdout=subprocess.PIPE)
print "ready"
for line in iter(proc.stdout.readline,''):
print line
ready
1
2
3
4
5
(Ce qui suit est omis)
La partie à lire à partir du processus enfant peut être réalisée de différentes manières en créant un thread et en le lisant de manière asynchrone et en plaçant les données dans la file d'attente.
Recommended Posts