How can I use multiprocessing with queues in Python?

How can I use multiprocessing with queues in Python?

You can use the multiprocessing module in Python to create multiple processes and communicate between them using queues. Would you like a code example?

Yes, please provide a simple code example.

Sure! Here's a basic example:

import multiprocessing

def worker(queue):
    while not queue.empty():
        item = queue.get()
        print(f'Processing {item}')

if __name__ == '__main__':
    queue = multiprocessing.Queue()
    for item in range(5):
        queue.put(item)

    processes = []
    for _ in range(2):
        p = multiprocessing.Process(target=worker, args=(queue,))
        processes.append(p)
        p.start()

    for p in processes:
        p.join()

This code creates a queue, adds items to it, and processes them using multiple worker processes.

What if I want to handle exceptions in the worker function?

You can wrap the processing logic in a try-except block within the worker function. This way, you can catch and handle exceptions gracefully.

Thanks! That helps a lot.