使用greenlet同时执行多个功能的问题

Question

以下脚本的目的是同时执行许多功能，但我不知道为什么它不能正常工作。
函数按顺序执行，而不是并行执行。

如果我有任何建议来澄清我做错了什么，我将不胜感激。

import time
import eventlet


EXECUTION_TIMEOUT = 10

def example(name, steps_limit):
    print 'Starting process %s with %d steps' % (name, steps_limit)
    for i in range(1, steps_limit+1):
        print "Process %s, step %d" % (name, i)
        time.sleep(2)
    print 'Finishing process %s with %d steps' % (name, steps_limit)


def fetch(input_data):
    example(input_data['name'], input_data['steps'])

test_data = [{'name':'proceso1', 'steps':3},
             {'name':'proceso2', 'steps':5},
             {'name':'proceso3', 'steps':6},
             ]

def main():
    #Setting up time out
    timeout = eventlet.timeout.Timeout(EXECUTION_TIMEOUT)
    #initialize pool
    pool = eventlet.GreenPool(size=1000)
    try:
        for hits in pool.imap(fetch, test_data):
            pass
    except eventlet.Timeout:
        print 'Operation interrupted by timeout concept'
    finally:
        timeout.cancel()


if __name__ == '__main__':
    main()

Answer 1

time.sleep() 是罪魁祸首是对的。

但您不必将time.sleep() 替换为eventlet.sleep()。相反，您可以将 time.sleep 修改为 eventlet.sleep。

事实上，这是首选，因为这样你不知道使用 time.sleep 的库也会得到修复，而如果你自己修复它，你只会修复你的代码。

因此，在gevent 中，我们只建议为所有程序调用gevent.monkey.patch_all()。在eventlet中，也有类似的功能。