进程间通信-Queue
队列：先进先出
栈：先进后出，后进先出
理解：直上直下电梯相当于栈，斜坡电梯相当于队列
队列可以存储任何数据类型
进程通信
from multiprocessing import Queue
线程通信
from queue import Queue
Queue队列的操作
from multiprocessing import Queue
#设置队列放入几个数据
q = Queue(3)
#查看队列的数据的数量
q.qsize()
#添加数据(1)
# 添加超出3条堵塞，超出添加不成功
q.put("哈哈")
#添加数据(2)
# 添加超出数据，会报错
q.put_nowait("哈哈")
#取出数据(1)
# 取出超出存的数据，会堵塞
q.get()
#取出数据(2)
# 取出超出存的数据，会报错
q.get_nowait()
#判断队列是否为空,True为空，False为假
q.empty()
#判断队列是否满？True满，False不满
q.full
进程中通信传参数
#在父进程中创建两个子进程，一个往Queue里写数据，一个从Queue里读数据
from multiprocessing import Process,Queue
import os
def write(q):
for value in ["a","b","c"]:
print("put %s to queue--%s"%(value,os.getpid()))
q.put(value)
def read(q):
while True:
if not q.empty():
value = q.get()
print("get %s from Queue--%s"%(value,os.getpid()))
else:
print("没有数据")
break
if __name__ == '__main__':
#在父进程里面创建队列
#这个队列的大小是无限
q = Queue()
#创建两个进程，pw进程负责写入数据，pr进程负责读取数据
pw = Process(target=write,args=(q,))
pr = Process(target=read,args=(q,))
pw.start()
pr.start()
#主进程等子进程结束在结束
pw.join()
pr.join()
