Lines Matching full:_state
141 self._state = RUN
166 self._worker_handler._state = RUN
176 self._task_handler._state = RUN
184 self._result_handler._state = RUN
243 assert self._state == RUN
250 assert self._state == RUN
257 assert self._state == RUN
275 assert self._state == RUN
293 assert self._state == RUN
302 assert self._state == RUN
325 while thread._state == RUN or (pool._cache and thread._state != TERMINATE):
341 if thread._state:
342 debug('task handler found thread._state != RUN')
394 if thread._state:
395 assert thread._state == TERMINATE
396 debug('result handler found thread._state=TERMINATE')
409 while cache and thread._state != TERMINATE:
438 debug('result handler exiting: len(cache)=%s, thread._state=%s',
439 len(cache), thread._state)
457 if self._state == RUN:
458 self._state = CLOSE
459 self._worker_handler._state = CLOSE
463 self._state = TERMINATE
464 self._worker_handler._state = TERMINATE
469 assert self._state in (CLOSE, TERMINATE)
491 worker_handler._state = TERMINATE
492 task_handler._state = TERMINATE
499 result_handler._state = TERMINATE
