Lines Matching refs:workers
70 # create processs pool with enough workers to spin all CPUs
73 workers = max(16, cpus * 2)
74 pool = multiprocessing.Pool(workers)
78 logging.info('starting %d workers', workers)
79 results = [pool.apply_async(cpu_stress) for _ in xrange(workers)]
96 # check workers: if computation completed, something is wrong
103 # kill off the workers
104 logging.info('killing %d workers', workers)
