B °F.\<ã@s’ddlmZmZmZddlmZddlZddlZddl m Z ddl m Z ddl mZddlmZe jdd „ƒZe jd d „ƒZGd d „d ejƒZdS)é)Úprint_functionÚdivisionÚabsolute_importN)Úmerge)Úgené)Útime)Úsyncc cs‚|jddV}|j}|dkr(| |¡nV|dkrB| ¡| ¡n.cf_callback)ÚcfZFutureZadd_done_callbackrÚloopZ add_callbackr)r$rrr'r)rrÚ _wrap_future?s   zClientExecutor._wrap_futurecOs@|jrtdƒ‚|jj|f|žt|j|ƒŽ}|j |¡| |¡S)a/Submits a callable to be executed with the given arguments. Schedules the callable to be executed as ``fn(*args, **kwargs)`` and returns a Future instance representing the execution of the callable. Returns ------- A Future representing the given call. z*cannot schedule new futures after shutdown) r"Ú RuntimeErrorrÚsubmitrr#r!Úaddr*)r$ÚfnÚargsr%rrrrr,Os  zClientExecutor.submitcsn| dd¡‰ˆdk rˆtƒ‰d|kr,|d=|r@tdt|ƒƒ‚ˆjj|f|žˆjŽ‰‡‡‡‡fdd„}|ƒS)a÷Returns an iterator equivalent to ``map(fn, *iterables)``. Parameters ---------- fn: A callable that will take as many arguments as there are passed iterables. iterables: One iterable for each parameter to *fn*. timeout: The maximum number of seconds to wait. If None, then there is no limit on the wait time. chunksize: ignored. Returns ------- An iterator equivalent to: ``map(fn, *iterables)`` but the calls may be evaluated out-of-order. Raises ------ TimeoutError: If the entire result iterator could not be generated before the given timeout. Exception: If ``fn(*args)`` raises for any values. ÚtimeoutNZ chunksizez!unexpected arguments to map(): %sc 3sœzfx`ˆD]X}ˆj |¡ˆdk rVy| ˆtƒ¡VWq`tjk rRtj‚Yq`Xq| ¡VqWWdtˆƒ}x|D]}ˆj |¡qvWˆj  |¡XdS)N) r!r-rrrÚ TimeoutErrorr(Úlistrr )rZ remaining)Úend_timeÚfsr$r0rrÚresult_iteratorƒs   z+ClientExecutor.map..result_iterator)ÚpoprrrrÚmapr#)r$r.Ú iterablesr%r5r)r3r4r$r0rr7_s   zClientExecutor.mapTcCs<|js8d|_t|jƒ}|r,t|jjt|ƒn |j |¡dS)ašClean-up the resources associated with the Executor. It is safe to call this method several times. Otherwise, no other methods can be called after this one. Parameters ---------- wait: If True then shutdown will not return until all running futures have finished executing. If False then all running futures are cancelled immediately. TN)r"r2r!r rr)rr )r$Úwaitr4rrrÚshutdown–s  zClientExecutor.shutdownN)T) Ú__name__Ú __module__Ú __qualname__Ú__doc__Ú frozensetrr&r*r,r7r:rrrrr.s 7r)Z __future__rrrZconcurrent.futuresrr(rr ZtoolzrZtornadorZmetricsrZutilsr Ú coroutinerrZExecutorrrrrrÚs