python 进程 Queue

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