1 """ 2 队列 3 q = Queue(5) # 创建一个最大容量为5的队列，先进先出的原则 4 q.put("1") # 添加元素，队列数量满了的时候，会堵在put处 5 q.put("1", timeout=3) # 如果超出3秒没有加入进去就会报错 6 q.put_nowait("6") # 不等，如果满了，直接报错 7 q.full() # 如果队列已满就返回True 8 9 q.get() # 先进先出的原则取出元素，没有元素将堵塞在这 10 q.get(timeout=3) # 如果超出3秒没有获取到就会报错 11 q.get_nowait() # 不等，如果空了，直接报错 12 q.empty() # 是否是空 13 14 q.join() # 阻塞 15 """ 16 17 from multiprocessing import Queue 18 19 q = Queue(5) # 创建一个最大容量为5的队列 20 q.put("1", timeout=3) 21 q.put("2") 22 q.put("3") 23 q.join() 24 q.put("4") 25 q.put("5") 26 print(q.qsize()) 27 q.close() 28 q.get() 29 q.get() 30 q.get() 31 q.get() 32 q.get() 33 q.get_nowait() 34 35 36 37 print("over")