dubbo 消费者线程池 消费者多线程

目录

• 生产者消费者模型

• 为什么要使用生产者和消费者模式
• 什么是生产者消费者模式
• 代码

记录一下对于多线程的理解吧

生产者消费者模型

在并发编程中使用生产者和消费者模式能够解决绝大多数并发问题。该模式通过平衡生产线程和消费线程的工作能力来提高程序的整体处理数据的速度。

为什么要使用生产者和消费者模式

在线程世界里，生产者就是生产数据的线程，消费者就是消费数据的线程。在多线程开发当中，如果生产者处理速度很快，而消费者处理速度很慢，那么生产者就必须等待消费者处理完，才能继续生产数据。同样的道理，如果消费者的处理能力大于生产者，那么消费者就必须等待生产者。为了解决这个问题于是引入了生产者和消费者模式。

什么是生产者消费者模式

生产者消费者模式是通过一个容器来解决生产者和消费者的强耦合问题。生产者和消费者彼此之间不直接通讯，而通过阻塞队列来进行通讯，所以生产者生产完数据之后不用等待消费者处理，直接扔给阻塞队列，消费者不找生产者要数据，而是直接从阻塞队列里取，阻塞队列就相当于一个缓冲区，平衡了生产者和消费者的处理能力。

代码

from threading import Thread
import time
from queue import Queue
import random
class Producer(Thread):
    def __init__(self,name,que):
        super(Producer,self).__init__()
        self.name = name
        self.que = que

    def run(self):
        while True:
            if self.que.qsize() < 3:
                self.que.put('一个包子')
                print ('[%s]生产了一个包子，剩余包子[%s]'%(self.name,self.que.qsize()))
                time.sleep(20)
            else:
                print ('队列里的包子大于3')
                # time.sleep(random.randrange(5))
                time.sleep(30)

class Consumer(Thread):
    def __init__(self,name,que):
        super(Consumer,self).__init__()
        self.name = name
        self.que = que

    def run(self):
        while True:
            try:
                self.que.get_nowait()
                print ('[%s]消费了一个包子,剩余包子[%s]'%(self.name,self.que.qsize()))
            except Exception:
                print ('没有包子了')
            # time.sleep(random.randrange(2))
            time.sleep(1)

que = Queue()
for i in range(2):
    name = "生产者%d"%i
    p1 = Producer(name,que)
    p1.start()
for i in range(2):
    name = "消费者%d"%i
    c1 = Consumer(name,que)
    c1.start()

现在情况是

1. 生产者生产完一个包子后需要30S生产第二个包子, 有两个生产者, 意思就是30S内可以生产两个包子.
2. 消费者吃包子很快,消费者也有两个,每个消费者吃掉一个包子后休息一秒钟,就会继续要包子,如果队列没有包子就会产生异常,输出没有包子了.
3. 也就是说每个消费者吃完包子后大概需要等待29S才能吃到第二个包子,所以也会输出38个”没有包子了“,才会输出 生产者生产包子的消息.