def _start_workers(self):
<EOL>log.debug('<STR_LIT>' %(self, self.worker_type, self.worker_num))<EOL>self.pool = []<EOL>for host, worker_num in[(None, self.worker_num)] + list(self.worker_remote):<EOL><INDENT>for _worker in range(worker_num):<EOL><INDENT>__worker = Thread(target=_pool_worker, args=(self._inqueue, self._outqueue, host))if self.worker_type == '<STR_LIT>' elseProcess(target=_pool_worker, args=(self._inqueue, self._outqueue, host))<EOL>self.pool.append(__worker)<EOL><DEDENT><DEDENT>for __worker in self.pool:<EOL><INDENT>__worker.daemon = True<EOL>__worker.start()<EOL><DEDENT>log.debug('<STR_LIT>' % self)<EOL>
(internal) starts **worker pool** threads or processes.