生产者每次生产一个产品

消费者每次消费两个产品 

采用了FIFO模式

queue4 = queue.Queue()
goods = 1
lock = threading.Lock()
def Productor(name):
    '''生产者'''
    global goods
    while True:
        lock.acquire()
        queue4.put("商品:{}".format(goods))
        print(name,"生产 商品:{}".format(goods))
        goods += 1
        lock.release()
        time.sleep(1)

def Customer(name):
    '''消费者'''
    while True:
        str1 = queue4.get()
        str2 = queue4.get()
        print(name, '消耗',str1,str2)
        queue4.task_done()
        time.sleep(1)


productor1 = threading.Thread(target=Productor, args=('生产者a',))
productor2 = threading.Thread(target=Productor, args=('生产者b',))
customer1 = threading.Thread(target=Customer, args=('消费者a',))
customer2 = threading.Thread(target=Customer, args=('消费者b',))
customer3 = threading.Thread(target=Customer, args=('消费者c',))
productor1.start()
productor2.start()
customer1.start()
customer2.start()
customer3.start()

 

运行以后的控制台输出结果:

生产者a 生产 商品:1
生产者b 生产 商品:2
消费者a 消耗 商品:1 商品:2
生产者a 生产 商品:3
生产者b 生产 商品:4
生产者a 生产 商品:5
消费者b 消耗 商品:3 商品:5
生产者b 生产 商品:6
生产者a 生产 商品:7
消费者c 消耗 商品:4 商品:7
生产者b 生产 商品:8
消费者a 消耗 商品:6 商品:8
生产者b 生产 商品:9
生产者a 生产 商品:10
消费者a 消耗 商品:9 商品:10
生产者b 生产 商品:11
生产者a 生产 商品:12
生产者a 生产 商品:13
生产者b 生产 商品:14
消费者c 消耗 商品:11 商品:14

提问:生产者生产了商品3,4,5后,消费者却按3,5的顺序消费??有人知道是为什么吗

原因:因为消费者的线程再交替进行,消费者b消耗3,消费者c消耗4

代码可优化,添加上队列是否满,是否空的判断

本文地址:https://blog.csdn.net/weixin_42784766/article/details/110928316