1、Queue的方法
实例化Queue(),未指定可接收信息的参数或该参数为负数,则默认无上限(内存上限)
Queue.qsize(): 返回当前队列包含消息的数量
Queue.empty(): 判断队列是否为空,是为True,否为False
Queue.full(): 判断队列是否满了,是为True,否为False
Queue.get([block[,timeout]]): 获取一条队列的消息,然后将其从队列中删除,black默认为True
如果block为默认值,没有设置timeout,消息队列又为空,那么此时程序将会阻塞(停在读取状态),直到队列中有值,从消息队列中读取到值.如果设置了timeout,等待timeout的时间就会报出(Queue.Empty)异常
如果block为False,消息队列为空,则会立刻抛出(Queue.Empty)异常
2、实例化
frommultiprocessingimportQueue q=Queue(3)#在实例化时传入消息队列的数量 q.put("test1") q.put("test2") print(q.full())#这里队列未满,返回False q.put("test3") print(q.full())#这里队列已经满了,返回True try: q.put("test4",timeout=2)#在写入时,如果队列是满的,就等待两秒钟,如还不可以,抛出异常 except: print("当前消息队列的数量为%s"%q.qsize()) try: q.put("test4",block=False)#在写入时,如果队列是满的,直接抛出异常 except: print("当前消息队列的数量为%s"%q.qsize()) #在写入之前,可以判断下队列是否是满的 ifnotq.full(): q.put_nowait("test4") #同理,在取数之前,判断队列是否为空 ifnotq.empty(): foriinrange(q.qsize()): print(q.get_nowait())
声明:本站所有文章,如无特殊说明或标注,均为本站原创发布。任何个人或组织,在未征得本站同意时,禁止复制、盗用、采集、发布本站内容到任何网站、书籍等各类媒体平台。如若本站内容侵犯了原著者的合法权益,可联系我们进行处理。
评论(0)