Lines Matching refs:condition
230 message, condition = self._queue.get()
231 condition.acquire()
233 condition.notify()
234 condition.release()
239 condition = threading.Condition()
240 condition.acquire()
241 self._queue.put((message, condition))
242 condition.wait()
247 self._queue.put((message, threading.Condition()))
