gevent_task_launcher.py

import gevent.monkey; gevent.monkey.patch_all();
import gevent.queue
import functools
import time
import random

Q = gevent.queue.Queue()

QUIT = "QUIT"

def launcher():
    coroutines = []
    for task in Q: 
        if task == QUIT:
            break
        print "going to launch %s" % task
        coroutine = gevent.spawn(task)
        coroutines.append(coroutine)
    print "Waiting for all coroutines..."
    gevent.joinall(coroutines)

def task(arg):
    print "task %s starting" % arg
    time.sleep(random.random() * 10)
    print "task %s done" % arg

def main():
    launcher_routine = gevent.spawn(launcher)
    counter = 1
    try:
        while True:
            Q.put(functools.partial(task, counter))
            counter += 1
            time.sleep(random.random() * 10)
    except KeyboardInterrupt:
        Q.put(QUIT)
    
    launcher_routine.join()

if __name__ == '__main__':
    main()