Compartir una cola de resultados entre varios procesos usando multiprocesamiento.Manager

En el multiprocesamiento, compartir una cola entre los procesos padre e hijo es esencial para la comunicación y la recuperación de resultados. Sin embargo, usar apply_async para iniciar procesos de trabajo asincrónicos presenta desafíos al compartir colas.

Para superar el error "Los objetos de la cola solo deben compartirse entre procesos mediante herencia", podemos utilizar multiprocesamiento.Manager. Esta clase de administrador permite la creación y administración de recursos compartidos, incluidas colas.

Al encerrar nuestra creación de cola dentro del contexto multiprocesamiento.Manager(), podemos hacerla accesible a todos los trabajadores. Así es como se modifica el código:

if __name__ == '__main__':
    pool = multiprocessing.Pool(processes=3)
    m = multiprocessing.Manager()
    q = m.Queue()
    workers = pool.apply_async(worker, (33, q))

Ahora, cada trabajador puede interactuar con el objeto q compartido e informar los resultados al proceso base. Este enfoque permite una comunicación de resultados eficiente y confiable al tiempo que mantiene la naturaleza asincrónica de apply_async.