Python多线程的简单实现（生产者消费者模型）

__author__ = "JentZhang"

import time, threading, queue

q = queue.Queue(maxsize=10)  # 声明队列


def Producer(name):
    '''生产者'''
    count = 1
    while True:
        q.put(count)  # 往队列中添加数据
        print("[%s] 生产了第%s包子
" % (name, count))
        count += 1
        time.sleep(3)


def Consumer(name):
    '''消费者'''
    while True:
        i = q.get()  # 从队列中取数据
        print("====[%s] 吃了第%s个包子
" % (name, i))
        time.sleep(1)


'''设置多线程'''
p = threading.Thread(target=Producer, args=("Jent",))
c1 = threading.Thread(target=Consumer, args=("张三",))
c2 = threading.Thread(target=Consumer, args=("李四",))

'''线程开启'''
p.start()
c1.start()
c2.start()