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