worker.py 文件源码

def work(self):
        def workon(iap):
            pool = gevent.pool.Pool(self.poolsize)

            for i in range(self.poolsize):
                pool.spawn(iap.work)

            pool.join()

        gevent.joinall([gevent.spawn(workon, p) for p in self.processes])