进程间通信-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()