mailer_gevent.py 文件源码

def send_multi_concurrency(self, messages):
        greenlets = []
        _pool = pool.Pool(self.concurrency)        

        for message in messages:
            if self.sleep_interval > 0:
                time.sleep(self.sleep_interval)
            greenlets.append(_pool.spawn(self.send, message))        

        _pool.join()

        results = []
        for g in greenlets:
            results.append(g.value)

        return results