How to Clear a Multiprocessing Queue in Python?

Estimated read time 2 min read

In Python’s multiprocessing module, you can clear all items from a Queue object by calling its queue.clear() method. This method removes all items from the queue, leaving it empty.

Here’s an example of how to use the clear() method to clear a Queue:

import multiprocessing

# Create a new multiprocessing Queue
queue = multiprocessing.Queue()

# Add some items to the queue
queue.put(1)
queue.put(2)
queue.put(3)

# Clear the queue by calling its clear() method
queue.queue.clear()

# Verify that the queue is empty
print(queue.empty()) # Output: True

In this example, a new Queue is created and some items are added to it using the put() method. The clear() method is then called on the queue object to remove all items from the queue. Finally, the empty() method is called on the queue object to verify that it is empty.

Note that the clear() method only removes the items from the queue, but it does not close or delete the queue object itself. If you want to delete the Queue object entirely, you can simply reassign it to a new Queue object, like this:

queue = multiprocessing.Queue()
# ...
queue = multiprocessing.Queue()

This creates a new Queue object and assigns it to the queue variable, effectively deleting the previous Queue object.

You May Also Like

More From Author

+ There are no comments

Add yours

Leave a Reply