Podproces Pythona.Popen z wątku

Question

Próbuję uruchomić "rsync" przy użyciu modułu podprocesowego i Popen wewnątrz wątku. Po wywołaniu rsync muszę również przeczytać dane wyjściowe. Używam metody komunikacji, aby odczytać wynik. Kod działa poprawnie, gdy nie używam wątku. Wygląda na to, że kiedy używam wątku, zawiesza się on na połączeniu komunikacyjnym. Inną rzeczą, którą zauważyłem jest to, że kiedy ustawiam shell = False, nic nie odzyskają komunikacji podczas działania w wątku.

Answer 1

Nie dostarczamy żadnego kodu dla nas patrzeć, ale tutaj jest próbka, która robi coś podobnego do tego, co można opisać:

import threading 
import subprocess 

class MyClass(threading.Thread): 
    def __init__(self): 
     self.stdout = None 
     self.stderr = None 
     threading.Thread.__init__(self) 

    def run(self): 
     p = subprocess.Popen('rsync -av /etc/passwd /tmp'.split(), 
          shell=False, 
          stdout=subprocess.PIPE, 
          stderr=subprocess.PIPE) 

     self.stdout, self.stderr = p.communicate() 

myclass = MyClass() 
myclass.start() 
myclass.join() 
print myclass.stdout 

Answer 2

Oto wielka realizacja nie używając wątki: constantly-print-subprocess-output-while-process-is-running

import subprocess 

def execute(command): 
    process = subprocess.Popen(command, shell=True, stdout=subprocess.PIPE, stderr=subprocess.STDOUT) 
    output = '' 

    # Poll process for new output until finished 
    for line in iter(process.stdout.readline, ""): 
     print line, 
     output += line 


    process.wait() 
    exitCode = process.returncode 

    if (exitCode == 0): 
     return output 
    else: 
     raise Exception(command, exitCode, output) 

execute(['ping', 'localhost'])