linux下生产者和消费者问题

import threading
import time
import random

# 缓冲区大小
BUFFER_SIZE = 10
buffer = []
lock = threading.Lock()
not_full = threading.Condition(lock)
not_empty = threading.Condition(lock)

class Producer(threading.Thread):
    def run(self):
        global buffer
        while True:
            with not_full:
                while len(buffer) == BUFFER_SIZE:
                    not_full.wait()
                item = random.randint(1, 100)
                buffer.append(item)
                print(f"Produced {item}. Buffer: {buffer}")
                not_empty.notify()
            time.sleep(random.random())

class Consumer(threading.Thread):
    def run(self):
        global buffer
        while True:
            with not_empty:
                while len(buffer) == 0:
                    not_empty.wait()
                item = buffer.pop(0)
                print(f"Consumed {item}. Buffer: {buffer}")
                not_full.notify()
            time.sleep(random.random())

# 创建并启动生产者和消费者线程
for _ in range(3):
    Producer().start()
for _ in range(3):
    Consumer().start()