¿Cómo puedo saber cuándo murió un proceso hijo?

Question

En mi clase, ejecuto 4 procesos.

from multiprocessing import Process 

    procs = (
      Process(target=ClassOne, name='ClassOne'), 
      Process(target=ClassTwo, name='ClassTwo'), 
      Process(target=ClassThree, name='ClassThree'), 
      Process(target=ClassFour, name='ClassFour'), 
      ) 

    for p in procs: 
     p.daemon = False 
     p.start() 

Me gustaría recibir una notificación cuando uno de mis hijos haya fallecido, así puedo matar al otro y a mí mismo.

Answer 1

apenas define un manejador de señales para SIGCHLD, inspeccionar el marco devuelto por el niño acaba de muertos para recuperar la información que necesita de ella ... y si es necesario la salida() el padre también :)

Answer 2

Aquí hay una solución de Windows. Utiliza la llamada a la API WaitForMultipleObjects. Para Unix os.waitpid puede hacer el trabajo.

import multiprocessing as mp 
import ctypes 


SYNCHRONIZE = 0x00100000 
INFINITE = -1 


def mbox(msg): 
    ctypes.windll.user32.MessageBoxW(0, msg, u'spam', 0) 


if __name__ == '__main__': 

    # start 2 processes 
    procs = [mp.Process(target=mbox, args=(msg,)) for msg in u'ab'] 
    for p in procs: 
    p.start() 

    # wait for at least one process to terminate 
    handles = [ 
    ctypes.windll.kernel32.OpenProcess(SYNCHRONIZE, False, p.pid) 
    for p in procs] 
    array_type = ctypes.c_long * len(handles) 
    handle_array = array_type(*handles) 
    ctypes.windll.kernel32.WaitForMultipleObjects(
    len(handles), handle_array, False, INFINITE) 

    # terminate the rest 
    for p in procs: 
    p.terminate() 

    # exit 
    print 'done' 

Answer 3

La manera más simple sería esperar explícitamente hasta que todos los procesos se hayan realizado.

while multiprocessing.active_children(): 
    pass 

Esto no es un evento impulsado como podría querer, pero hará el trabajo en su ejemplo. También asegúrese de que import multiprocessing.

Answer 4

Se es posible usar os.waitpid() pasando -1 como el primer argumento y como el segundo.

• El primer argumento significa que la solicitud pertenece a cualquier elemento secundario del proceso actual.
• El segundo argumento significa que se comporta como wait().

La función devuelve una tupla con el pid del niño muerto y su código de salida.

Answer 5

Quizás desee consultar la clase AutoJoiningProcess en la respuesta al this similar question.

Si está preparado para agregar a su código una dependencia de gobject (parte de PyGTK), entonces AutoJoiningProcess le permitirá escuchar una señal que se emite cuando termina un proceso. En esa señal, podrías responder como quieras.