队列Joinablequeue的使用,以及生产者消费者模型的认识

队列

进程彼此之间相互隔离,要实现进程间的通讯(IPC),multiprocess模块支持两种形式:队列和管道,这两种方式都是使用消息传递的

创建队列的类:

Queue([maxsize]):创建共享的进程队列,Queue是多进程安全的队列,可以使用Queue实现多进程之间大的数据传递.

参数介绍及:

maxsize是队列中允许最大项数,省略则无大小限制.

方法介绍:

put:方法用于插入数据到队列中.put方法有两个可选参数:blocked和timeout.

get:该方法可以从队列读取并且删除一个元素.同样,get方法有两个可选参数:blocked和timeout.

put_nowait:用处同put,默认blocked = False

get_nowait:用处同get,默认blocked = False

empty:调用此方法时队列为空则返回True,该结果不可靠,比如在返回True的过程中,如果队列中又加入了项目.

full:调用此方法时队列已满则返回True,该结果不可靠,比如在返回True的过程中,如果队列中的项目被取走.

qsize:返回队列中目前项目的正确数量,结果看也不可靠,在返回结果后,队列有可能会发生变化.

生产者和消费者模型

from multiprocessing import Process,JoinableQueue
import time,random
def producer(q,name):
    for i in range(10):
        print(f'生产者生产了{name}')
        time.sleep(random.randint(1, 3))
        q.put(f'{name}')

def consumer(q,name):
    while True:
        res = q.get()
        time.sleep(random.randint(1, 3))
        print(f'{name}买到了{res}')
        q.task_done()

if __name__ == '__main__':
    que = JoinableQueue()
    p = Process(target=producer, args=(que, 'apple'))
    c = Process(target=consumer, args=(que, 'con'))
    p.start()
    c.daemon = True
    c.start()
    p.join()
    que.join()