Lines Matching refs:TERMINATE
56 TERMINATE = 2
324 while thread._state == RUN or (pool._cache and thread._state != TERMINATE):
382 assert thread._state == TERMINATE
383 debug('result handler found thread._state=TERMINATE')
396 while cache and thread._state != TERMINATE:
448 def terminate(self):
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
495 # Terminate workers which haven't already finished.
496 if pool and hasattr(pool[0], 'terminate'):
500 p.terminate()
510 if pool and hasattr(pool[0], 'terminate'):
