Lines Matching full:_state
141 self._state = RUN
166 self._worker_handler._state = RUN
175 self._task_handler._state = RUN
183 self._result_handler._state = RUN
242 assert self._state == RUN
249 assert self._state == RUN
256 assert self._state == RUN
274 assert self._state == RUN
292 assert self._state == RUN
301 assert self._state == RUN
324 while thread._state == RUN or (pool._cache and thread._state != TERMINATE):
338 if thread._state:
339 debug('task handler found thread._state != RUN')
381 if thread._state:
382 assert thread._state == TERMINATE
383 debug('result handler found thread._state=TERMINATE')
396 while cache and thread._state != TERMINATE:
425 debug('result handler exiting: len(cache)=%s, thread._state=%s',
426 len(cache), thread._state)
444 if self._state == RUN:
445 self._state = CLOSE
446 self._worker_handler._state = CLOSE
450 self._state = TERMINATE
451 self._worker_handler._state = TERMINATE
456 assert self._state in (CLOSE, TERMINATE)
478 worker_handler._state = TERMINATE
479 task_handler._state = TERMINATE
486 result_handler._state = TERMINATE
