¿Cómo compartes los datos entre un padre y el proceso hijo bifurcado en Python?

Question

Estoy bastante seguro de que uno haría esto usando la función os.plock (op), pero no tengo idea de cómo. Además, si hay una mejor manera, estaría agradecido de averiguarlo. Los fragmentos de código son muy bienvenidos.

Answer 1

Subprocess reemplaza os.popen, os.system, os.spawn, popen2 y comandos. Un simple example for piping sería:

p1 = Popen(["dmesg"], stdout=PIPE) 
p2 = Popen(["grep", "hda"], stdin=p1.stdout, stdout=PIPE) 
output = p2.communicate()[0] 

También es posible usar un memory mapped file con la bandera = MAP_SHARED para la memoria compartida entre los procesos.

multiprocessing resúmenes pipes y shared memory y proporciona una interfaz de nivel superior. Tomado de la documentación de procesamiento:

from multiprocessing import Process, Pipe 

def f(conn): 
    conn.send([42, None, 'hello']) 
    conn.close() 

if __name__ == '__main__': 
    parent_conn, child_conn = Pipe() 
    p = Process(target=f, args=(child_conn,)) 
    p.start() 
    print parent_conn.recv() # prints "[42, None, 'hello']" 
    p.join() 

Answer 2

¡Esto es prácticamente independiente de Python! Es un ejemplo clásico de comunicación interproceso de Unix. Una buena opción es usar popen() para abrir un conducto entre los procesos padre e hijo, y pasar datos/mensajes de ida y vuelta a lo largo del conducto.

Eche un vistazo a subprocess module, que puede configurar los conductos necesarios automáticamente al generar procesos secundarios.

Answer 3

Tiene dos opciones: os.popen* en el módulo os, o puede usar el módulo subprocess con el mismo efecto. El manual de Python tiene documentación y ejemplos bonitos para popen y subprocess.

Answer 4

Tome un vistazo a la multiprocessing módulo nuevo en Python 2.6 (también disponible para las versiones anteriores de un pyprocessing

He aquí un ejemplo de los documentos que ilustran la información que pasa usando un tubo, por ejemplo, :

from multiprocessing import Process, Pipe 

def f(conn): 
    conn.send([42, None, 'hello']) 
    conn.close() 

if __name__ == '__main__': 
    parent_conn, child_conn = Pipe() 
    p = Process(target=f, args=(child_conn,)) 
    p.start() 
    print parent_conn.recv() # prints "[42, None, 'hello']" 
    p.join()