使用Python实现阻塞队列（简单版）

在Python中，我们可以使用标准库中的queue模块来实现阻塞队列。下面是一个简单的阻塞队列的实现：

import threading
import queue
class BlockingQueue:
    def __init__(self, max_size):
        self.max_size = max_size
        self.queue = queue.Queue(max_size)
        self.lock = threading.Lock()
    def put(self, item):
        with self.lock:
            while self.queue.qsize() == self.max_size:  # 如果队列已满
                threading.Condition(self.lock).wait()  # 阻塞当前线程，等待其他线程释放空间
            self.queue.put(item)  # 添加元素到队列
            threading.Condition(self.lock).notify()  # 通知等待的线程队列有空余空间
    def get(self):
        with self.lock:
            while self.queue.qsize() == 0:  # 如果队列为空
                threading.Condition(self.lock).wait()  # 阻塞当前线程，等待其他线程添加元素
            item = self.queue.get()  # 从队列中获取元素
            threading.Condition(self.lock).notify()  # 通知等待的线程队列有新元素
            return item

这个简单的阻塞队列实现使用了queue模块和threading模块。queue模块提供了线程安全的队列实现，而threading模块提供了线程同步和互斥锁的实现。通过使用互斥锁，我们可以保证多线程访问共享资源时的安全。当队列满时，尝试添加元素的线程会被阻塞，直到有线程从队列中取出元素，释放空间。同样，当队列为空时，尝试获取元素的线程也会被阻塞，直到有线程向队列中添加元素。

注意：这个实现是一个简单的示例，可能不适用于所有场景。在实际应用中，你可能需要考虑更多的因素，例如异常处理、线程安全、性能优化等。