使用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中，也有类似的函数。