def process_condition(self): if self._condition == None: self._condition = multiprocessing.Condition() return self._condition