Python中的生产者-消费者模型及其实现方法

import threading
import time

# 缓存队列
queue = []
# 缓存队列的最大容量
MAX_LEN = 5

class Producer(threading.Thread):
    """生产者线程"""

    def run(self):
        global queue
        while True:
            # 在加入缓存前，需要获取锁
            lock.acquire()
            if len(queue) == MAX_LEN:
                print("队列已满，无法加入数据")
                # 释放锁
                lock.release()
                continue
            # 模拟数据的生产
            data = "pidancode.com"
            queue.append(data)
            print("生产数据：{}".format(data))
            # 释放锁
            lock.release()
            # 等待0.5秒
            time.sleep(0.5)

class Consumer(threading.Thread):
    """消费者线程"""

    def run(self):
        global queue
        while True:
            # 在取出缓存前，需要获取锁
            lock.acquire()
            if not queue:
                print("队列已空，无法取出数据")
                # 释放锁
                lock.release()
                continue
            # 模拟数据的消费
            data = queue.pop(0)
            print("消费数据：{}".format(data))
            # 释放锁
            lock.release()
            # 等待1秒
            time.sleep(1)

# 创建锁对象
lock = threading.Lock()

# 创建生产者和消费者线程
p = Producer()
c = Consumer()

# 启动线程
p.start()
c.start()