Searched refs:_NewThreadsafeQueue (Results 1 – 1 of 1) sorted by relevance
145 def _NewThreadsafeQueue(): function1317 task_queues.append(_NewThreadsafeQueue())1352 task_queue = _NewThreadsafeQueue()1644 self.task_queue = _NewThreadsafeQueue()