How do I use multiprocessing Queue in Python?

How do I use multiprocessing Queue in Python?

You can use the multiprocessing.Queue class to create a queue that can be shared between processes. It allows you to pass messages or data between them.

Can you show me a simple example?

Sure! Here's a basic example:

from multiprocessing import Process, Queue

def worker(q):
    q.put('Hello from the worker!')

if __name__ == '__main__':
    q = Queue()
    p = Process(target=worker, args=(q,))
    p.start()
    print(q.get())  # Output: Hello from the worker!
    p.join()

What if I want to pass multiple items?

You can put multiple items in the queue by calling q.put() multiple times. Here's an example:

from multiprocessing import Process, Queue

def worker(q):
    for i in range(5):
        q.put(i)

if __name__ == '__main__':
    q = Queue()
    p = Process(target=worker, args=(q,))
    p.start()
    while not q.empty():
        print(q.get())  # Outputs: 0, 1, 2, 3, 4
    p.join()