python 之生产者消费者模型

进程实现：

import time,random

from multiprocessing import Process,Queue

def producer(name,q):

    count= 0

    while count<10:

        print('making,,,,')

        time.sleep(2)

        q.put(count)

        print('Producer %s has produced %s baozi'%(name,count))

        count += 1

def consumer(name,q):

    count = 0

    while count <10:

        time.sleep(1)

        if not q.empty():

            data = q.get()

            print(data)

            print('consumer %s has eat %s baozi'%(name,count))

            count +=1

        else:

            print('no baozi')

if __name__ == '__main__':

    # 容器

    q = Queue()

    # 生产者们

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

    p.start()

    # 消费者们

    c = Process(target=consumer,args=('B',q,))

    c.start()