test_4.py 文件源码

def worker(n):
    try:
        while True:
            task = tasks.get(timeout=1) # decrements queue size by 1
            print('Worker %s got task %s' % (n, task))
            gevent.sleep(1.5)
    except Empty:
        print('Quitting time!')