Queue在python的实例化

from multiprocessing import Queue

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())

# 在写入之前,可以判断下队列是否是满的

if not q.full():

q.put_nowait("test4")

# 同理,在取数之前,判断队列是否为空

if not q.empty():

for i in range(q.qsize()):

print(q.get_nowait())