队列(Quene)

对multiprocessing中的Quene进行演示

 1 import multiprocessing
 2 """
 3 队列Quene是mutiprocessing 中 的一个类
 4 包括向队列中存数以及取数 等操作
 5 """
 6 quene = multiprocessing.Queue(4)
 7 quene.put(2)
 8 quene.put("hello")
 9 quene.put((1,2,3))
10 quene.put({"a":10,"b":20})
11 # 当向quene中存取数据超过quene的容量时,会对程序进行阻塞,此时使用put_nowait()进行存数时,会直接报错并终止程序。
12 quene.put_nowait(656)
13 value = quene.get()
14 print(value)
15 value = quene.get()
16 print(value)
17 value = quene.get()
18 print(value)
19 value = quene.get()
20 print(value)
21 # 当队列中的数据被取完时又执行get操作,会造成程序的阻塞,此时如果用get_nowait() 会直接终止程序的运行并报错
22 # value = quene.get_nowait()
23 print(value)


原文地址:https://www.cnblogs.com/liuxjie/p/11984902.html