How to do inter-process communication with pathos/ppft?
I’m using the pathos framework to do tasks concurrently, in different processes. Under the hood, this is done with ppft, which is part of pathos. My current approach uses a pathos.multiprocessing.ProcessPool instance. Multiple jobs are submitted to it, one at a time without blocking, using apipe(). The main process is then supervising the worker processes using ready() and get().
How to do inter-process communication with pathos/ppft?
I’m using the pathos framework to do tasks concurrently, in different processes. Under the hood, this is done with ppft, which is part of pathos. My current approach uses a pathos.multiprocessing.ProcessPool instance. Multiple jobs are submitted to it, one at a time without blocking, using apipe(). The main process is then supervising the worker processes using ready() and get().