def parallel(iterable, count, callable, *args, **named):
 coop = task.Cooperator()
 work = (callable(elem, *args, **named) for elem in iterable)
 return defer.DeferredList([coop.coiterate(work) for _ in range(count)])

def parallel ( iterable , count , callable , * args , ** named ) : coop = task . Cooperator ( ) work = ( callable ( elem , * args , ** named ) for elem in iterable ) return defer . DeferredList ( [ coop . coiterate ( work ) for _ in range ( count ) ] )
execute a callable over the objects in the given iterable .