python生产者和消费者模式实现(一)

标签：rod   name   ftime   int   timeval   queue   process   ssi   消费者   

import time
import random
from multiprocessing import Queue


# 生产者
def producer(q, num):
    for i in range(1, num + 1):
        food = ‘Spam-%d‘ % i
        # time.sleep(random.uniform(1, 2))
        timeVal = time.strftime("%Y-%m-%d %H:%M:%S", time.localtime())
        print(‘时间：%s\t生产者：%d 生产了 %d‘ % (timeVal, i, i))
        q.put(food)


# 消费者
def consumer(q):
    while True:
        food = q.get()
        if not food:
            break
        # time.sleep(random.uniform(1, 2))
        timeVal = time.strftime("%Y-%m-%d %H:%M:%S", time.localtime())
        print(‘时间：%s\t消费者吃了 %s‘ % (timeVal, food))


if __name__ == ‘__main__‘:
    q = Queue()
    num = 50
    # 生产者
    producer(q, num)
    q.put(None)
    # 消费者
    consumer(q)

    print(‘end‘)

python生产者和消费者模式实现(一)

标签：rod   name   ftime   int   timeval   queue   process   ssi   消费者   

原文地址：https://www.cnblogs.com/WebLinuxStudy/p/11776715.html