记录型信号量生产者消费者问题python

记录型信号量（Record Semaphores）是解决生产者-消费者问题的一种数据结构和算法策略，它在Python中通常通过内置的`threading`模块配合`Semaphore`类来实现。在这个问题中，我们有两个角色：生产者（Producer）负责生成产品放入缓冲区，消费者（Consumer）则从缓冲区取出并消费产品。

Python实现的基本步骤如下：

1. **创建资源**：定义一个信号量，初始值设置为缓冲区的容量。

import threading
semaphore = threading.Semaphore(buffer_size)

2. **生产者循环**：生产者获取信号量，在缓冲区满之前继续生产，并释放信号量。

def producer(product_queue):
    while True:
        semaphore.acquire()
        # 生产产品并加入队列
        product_queue.append("Product")
        print(f"Produced {product_queue[-1]}")
        semaphore.release()

3. **消费者循环**：消费者获取信号量，检查缓冲区是否为空。如果空，则等待；非空则消费并减少信号量。

def consumer(product_queue):
    while True:
        semaphore.acquire()
        if not product_queue:
            print("Buffer is empty, waiting...")
            semaphore.release()  # 先释放信号量，然后等待
            semaphore.acquire()  # 当有产品时再次获取
        else:
            product = product_queue.pop(0)
            print(f"Eaten {product}")
            semaphore.release()

4. **启动线程**：创建生产者和消费者的线程实例，然后启动它们。