Problema al utilizar greenlet para ejecutar múltiples funciones simultáneamente

Question

El siguiente script tiene el propósito de ejecutar muchas funciones simultáneamente, pero no tengo idea de por qué no está funcionando correctamente.
Las funciones se ejecutan de forma secuencial, no paralela.

Agradecería cualquier sugerencia para aclararme, sobre lo que estoy haciendo mal.

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

Tienes razón en time.sleep() es el culpable.

Pero no es necesario reemplazar time.sleep() con eventlet.sleep(). En cambio, puede parche mono time.sleep para convertirse en eventlet.sleep.

Esto es, de hecho, preferido, porque de esa manera las bibliotecas que no conoces usan time.sleep también se arreglan, mientras que si lo arreglas tú mismo, solo arreglaste tu código. Por este motivo, en gevent, recomendamos llamar al gevent.monkey.patch_all() para todos los programas. En eventlet, existe una función similar existe.