python入门教程12-08 （python语法入门之进程间通讯）

在讲解多线程时，介绍了 3 种实现线程间通讯的机制，一样 Python 也提供了多种实现进程间通讯的机制，下面咱们一块儿来看看吧。

进程间通讯

咱们知道进程之间数据是相互隔离的，要想实现进程间的通讯(IPC机制),就必须借助于一些技术才能够，好比multiprocessing模块中的：队列和管道，这两种方式都是能够实现进程间数据传输的，因为队列是管道+锁的方式实现，因此咱们着重研究队列便可

队列

概念介绍

建立共享的进程队列，Queue是多进程安全的队列，可使用Queue实现多进程之间的数据传递。

大白话总结一下就是队列支持多我的从队列的一端放入数据，一样支持多我的从队列的另外一端取数据

基本用法

Queue([maxsize]) # 建立共享的进程队列 队列底层使用管道和锁定实现。# 参数 ：maxsize是队列中容许的最大项数。若是省略此参数，则无大小限制。

代码实现

from multiprocessing import Queue

q=Queue(3) # 建立一个最大只能容纳3个数据的队列"""

经常使用方法

put ,get ,put_nowait,get_nowait,full,empty

"""q.put(3) # 往队列中存放数据q.put(3)

q.put(3)

q.put(3) # 若是队列已经满了，程序就会停在这里，等待数据被别人取走，再将数据放入队列。若是队列中的数据一直不被取走，程序就会永远停在这里。try:

q.put_nowait(3) # 可使用put_nowait，若是队列满了不会阻塞，可是会由于队列满了而报错。except:  # 所以咱们能够用一个try语句来处理这个错误。这样程序不会一直阻塞下去，可是会丢掉这个消息。    print('队列已经满了')

# 所以，咱们再放入数据以前，能够先看一下队列的状态，若是已经满了，就不继续put了。print(q.full())  # 判断队列中数据是否已存放满了print(q.get())  # 从队列中获取数据print(q.get())

print(q.get())

print(q.get()) # 同put方法同样，若是队列已经空了，那么继续取就会出现阻塞。try:

q.get_nowait(3) # 可使用get_nowait，若是队列满了不会阻塞，可是会由于没取到值而报错。except: # 所以咱们能够用一个try语句来处理这个错误。这样程序不会一直阻塞下去。    print('队列已经空了')

print(q.empty()) # 判断队列中数据是否已经被所有取出

基于队列实现进程间通讯

import timefrom multiprocessing import Process, Queuedeff(q): q.put('hello') #调用主函数中p进程传递过来的进程参数 put函数为向队列中添加一条数据。if name == 'main':

q = Queue()  # 建立一个Queue对象    p = Process(target=f, args=(q,)) #建立一个进程    p.start()

print(q.get())  # 从队列中获取数据    p.join()from multiprocessing import Queue,Processdefproducer(q):    q.put('hello big baby!')defconsumer(q):    print(q.get())if __name__ == '__main__':

q = Queue()

p = Process(target=producer,args=(q,))

p.start()

p1 = Process(target=consumer,args=(q,))

p1.start()