具有非空队列的 Python Queue.get(block=False)。它可以引发 Queue.empty 吗？

Question

我正在使用 python 的 Queue.Queue 来同步多个线程。首先，队列中填充了 N 个元素，如

N = 10
q = Queue.Queue()
for i in range(N):
  q.put(i)

然后，多个线程使用 block=False 来消费队列中的元素

q.get(block=False)

我的问题是:之前对 Queue.get() 的调用能否在前 N 个调用中的任何一个中引发 Queue.Empty？

谢谢!

Answer 1

对 get() 的前 N 次调用将成功； q.get(block=False) 只会在队列实际为空时引发 Queue.Empty。您的线程对 get 的所有调用都是同步的，因此获得 Queue 使用的互斥锁的前 N ​​个线程将成功 get Queue 中的项。如果您有 N+1 个或更多线程，则第 N 个之后的任何 get 都会引发 Queue.Empty。通过查看 Queue 代码的相关部分，您可以很容易地看到这一点，如 Eric 所述。 .

class Queue:
    """Create a queue object with a given maximum size.

    If maxsize is <= 0, the queue size is infinite.
    """
    def __init__(self, maxsize=0):
        self.maxsize = maxsize
        self._init(maxsize)
        self.mutex = _threading.Lock()
        self.not_empty = _threading.Condition(self.mutex)
        ... # Stuff we don't care about

    def get(self, block=True, timeout=None):
        self.not_empty.acquire() # Only on thread can hold this at a time
        try:
            if not block:
                if not self._qsize(): # If there's nothing in the Queue
                    raise Empty
            ... # Other stuff we don't care about, since you use block=False
            item = self._get()
            self.not_full.notify()
            return item
        finally:
            self.not_empty.release()

    def _init(self, maxsize):
        self.queue = deque()

    def _qsize(self, len=len):
        return len(self.queue)