Lines Matching refs:threading
41 import threading
161 self._worker_handler = threading.Thread(
170 self._task_handler = threading.Thread(
179 self._result_handler = threading.Thread(
321 thread = threading.current_thread()
334 thread = threading.current_thread()
385 thread = threading.current_thread()
505 if threading.current_thread() is not worker_handler:
516 if threading.current_thread() is not task_handler:
520 if threading.current_thread() is not result_handler:
538 self._cond = threading.Condition(threading.Lock())
635 self._cond = threading.Condition(threading.Lock())
