multiprocessing.Manager().Queue() 清空
时间: 2023-06-23 11:46:55 浏览: 476
Python multiprocessing.Manager介绍和实例(进程间共享数据)
使用 `multiprocessing.Manager().Queue()` 创建的队列对象,可以直接调用 `queue.Queue` 对象的 `queue.clear()` 方法来清空队列。示例代码如下:
```python
from multiprocessing import Manager
manager = Manager()
q = manager.Queue()
# 往队列中添加元素
q.put(1)
q.put(2)
q.put(3)
# 清空队列
q.queue.clear()
# 验证队列是否为空
print(q.empty()) # 输出 True
```
在上述代码中,我们首先使用 `multiprocessing.Manager()` 创建了一个进程间共享的 `queue.Queue` 对象,并往队列中添加了三个元素。接着,我们调用了 `queue.clear()` 方法来清空队列,最后使用 `queue.empty()` 方法来验证队列是否为空。
阅读全文