Lines Matching defs:worker
77 # Code run by worker processes
97 def worker(inqueue, outqueue, initializer=None, initargs=(), maxtasks=None,
116 util.debug('worker got EOFError or OSError -- exiting')
120 util.debug('worker got sentinel -- exiting')
140 util.debug('worker exiting after %d tasks' % completed)
286 return [worker.sentinel for worker in
287 workers if hasattr(worker, "sentinel")]
291 """Cleanup after any worker processes which have exited due to reaching
296 worker = pool[i]
297 if worker.exitcode is not None:
298 # worker exited
299 util.debug('cleaning up worker %d' % i)
300 worker.join()
322 w = Process(ctx, target=worker,
331 util.debug('added worker')
525 util.debug('worker handler exiting')
705 # We must wait for the worker handler to exit before terminating
707 util.debug('joining worker handler')
730 # worker has not yet exited
731 util.debug('cleaning up worker %d' % p.pid)