feed2.py 文件源码

def parallel(iterable, parallel_count, callable, *args, **named):
    coop = task.Cooperator()
    work = (callable(elem, *args, **named) for elem in iterable)
    dl = defer.DeferredList([coop.coiterate(work) for i in xrange(parallel_count)])
    return dl