worker.py 文件源码

def test_throttling():
    def printget():
        print time.time(), 'id' in get_item(22183623058)

    import gevent.pool
    pool = gevent.pool.Pool(20)
    while True:
        pool.spawn(call_with_throttling, printget, threshold_per_minute=600)
    pool.join()