Sometimes, we want to share a result queue among several processes with Python.
In this article, we’ll look at how to share a result queue among several processes with Python.
How to share a result queue among several processes with Python?
To share a result queue among several processes with Python, we use the Queue class.
For instance, we write
import multiprocessing
def worker(name, que):
que.put("%d is done" % name)
if __name__ == '__main__':
pool = multiprocessing.Pool(processes=3)
m = multiprocessing.Manager()
q = m.Queue()
workers = pool.apply_async(worker, (33, q))
to create a queue from the Manager object with m.Queue.
Then we call pool.apply_async with the worker function and (33, q) to call worker with 33 and queue q as the arguments.
In worker, we call que.put to return a result after worker is done running.
Conclusion
To share a result queue among several processes with Python, we use the Queue class.
