qsize方法的坑
qsize方法是在Windows平台上能用的,但是在Unix平台比如Linux和mac就不行了,会报错:NotImplementedError
。
python
from multiprocessing import Queue
if __name__ == '__main__':
# 创建一个队列,最多可以接收3条消息
q = Queue(3)
print('队列中消息的个数:', q.qsize())
具体参考官档:https://docs.python.org/zh-cn/3/library/multiprocessing.html#multiprocessing.Queue.qsize
解决方式是:
python
# from multiprocessing import Queue
from queue import Queue
if __name__ == '__main__':
# 创建一个队列,最多可以接收3条消息
q = Queue(3)
print('队列中消息的个数:', q.qsize())