在Python中构建阻塞的零长度队列的好方法

Question

在Java中，有java.util.concurrent.SynchronousQueue，一个没有存储容量的队列。尝试放置/获取值的线程总是阻塞，直到另一个线程分别尝试获取/放置值为止。在

在Python中有什么好方法可以实现同样的效果？一、 我想要一种方法来将值从一个或多个线程集传递到另一个一个或多个线程集，而不必“属于”任何一个组中的线程。在

Python的queue.Queue不允许长度为0，为最大容量指定一个非正值将创建一个无界队列。在

Answer 1

您可以使用Queue.join()和Queue.task_done()来阻止，直到get()完成：

class SynchronousQueue(object):

    def __init__(self):
        self.q = Queue(1)
        self.put_lock = RLock()

    def get(self):
        value = self.q.get(block=True)
        self.q.task_done()
        return value

    def put(self, item):
        with self.put_lock:
            self.q.put(item, block=True)
            self.q.join()