preforkjava.py 文件源码

def init_task_pool(self):
        # lazy creation, and set a common pool for all task consumers
        pool = self.pool = []
        for i in range(self.numjobs):
            consumer = Runner.get_pool()
            pool.append(consumer)
            consumer.idx = i
        self.ready = Queue(0)
        def setq(consumer):
            consumer.ready = self.ready
            try:
                threading.current_thread().idx = consumer.idx
            except Exception as e:
                print(e)
        for x in pool:
            x.ready.put(setq)
        return pool