Lines Matching full:mutex
29 # mutex must be held whenever the queue is mutating. All methods
30 # that acquire mutex must release it before returning. mutex
32 # releasing the conditions also acquires and releases mutex.
33 self.mutex = _threading.Lock()
36 self.not_empty = _threading.Condition(self.mutex)
39 self.not_full = _threading.Condition(self.mutex)
42 self.all_tasks_done = _threading.Condition(self.mutex)
88 self.mutex.acquire()
90 self.mutex.release()
95 self.mutex.acquire()
97 self.mutex.release()
102 self.mutex.acquire()
104 self.mutex.release()
