Ë
|
Ñ^i ã óz d Z ddlmZ ddlmZ ddlmZ ddlmZ ddl
|
m Z dd giZ d
|
d gZ edd « Zd Zd Zd Zy)z,
|
Thin wrappers around `concurrent.futures`.
|
é )Úcontextmanager)Ú length_hint)Ú cpu_counté )Útqdm)Ú TqdmWarningz github.com/Ú casperdclÚ
|
thread_mapÚ process_mapc # ó¾ K t | dd« }|xs | j « }t |||« }| j |« | || `y| j |« yw)z>get (create if necessary) and then restore `tqdm_class`'s lockÚ_lockN)ÚgetattrÚget_lockÚset_lockr )Ú
|
tqdm_classÚ lock_nameÚold_lockÚlocks õj H:\项ç®\archive\æµè¯ç»\èæ¬\Change_password\venv_build\Lib\site-packages\tqdm/contrib/concurrent.pyÚ ensure_lockr sd è ø ô z 7¨DÓ1HØ Ò ,z×*Ñ*Ó,DÜ 4 DÓ )DØ×ÑÔ Ø
|
JØÐØ Ñ à×ÑHÕ%ùs AA c ó |j « }d|vrt |d « |d< |j dt « }|j dt dt « dz « « }|j dd« }|j d d
|
« }t ||¬ « 5 } | ||j | f¬ « 5 }
|
t | |
|
j |g|¢d|ifi |¤« cd d d « cd d d « S # 1 sw Y nxY w d d d « y # 1 sw Y y xY w)a
|
Implementation of `thread_map` and `process_map`.
|
|
Parameters
|
----------
|
tqdm_class : [default: tqdm.auto.tqdm].
|
max_workers : [default: min(32, cpu_count() + 4)].
|
chunksize : [default: 1].
|
lock_name : [default: "":str].
|
Útotalr r Ú max_workersé é Ú chunksizeé r Ú )r )r Ú initializerÚinitargsN)
|
Úcopyr ÚpopÚ tqdm_autoÚminr r r ÚlistÚmap) Ú PoolExecutorÚfnÚ iterablesÚ tqdm_kwargsÚkwargsr r r r ÚlkÚexs r Ú _executor_mapr. s ð × Ñ Ó FØfÑ Ü% i°¡lÓ3wØL¬)Ó4JØ**]¬C°´I³KÀ!±OÓ,DÓEKØ
|
|
;¨Ó*IØ
|
|
;¨Ó+IÜ Z¨9Ô 5ð [¸á k¸z×?RÑ?RØ$& 5ô*ð [Ø-/Ü
|
6 2§6¡6¨"Ð#N¨yÒ#NÀIÑ#NÑYÐRXÑYÓZ÷ [ð [÷[ñ [÷ [ð [úð [÷[÷ [ñ [ús$ ÂC:Â+&C$Ã C:Ã$C- Ã)C:Ã:Dc ó. ddl m} t || g|¢i |¤S )a¢
|
Equivalent of `list(map(fn, *iterables))`
|
driven by `concurrent.futures.ThreadPoolExecutor`.
|
|
Parameters
|
----------
|
tqdm_class : optional
|
`tqdm` class to use for bars [default: tqdm.auto.tqdm].
|
max_workers : int, optional
|
Maximum number of workers to spawn; passed to
|
`concurrent.futures.ThreadPoolExecutor.__init__`.
|
[default: max(32, cpu_count() + 4)].
|
r )ÚThreadPoolExecutor)Úconcurrent.futuresr0 r. )r( r) r* r0 s r r
|
r
|
6 s õ 6Ü Ð+¨RÐ K°)Ò K¸{Ñ KÐKó c óØ ddl m} |r:d|vr6t t t |« « }|dkD rddlm} |d|z t d¬« d |vr|j « }d
|
|d < t || g|¢i |¤S ) a¦
|
Equivalent of `list(map(fn, *iterables))`
|
driven by `concurrent.futures.ProcessPoolExecutor`.
|
|
Parameters
|
----------
|
tqdm_class : optional
|
`tqdm` class to use for bars [default: tqdm.auto.tqdm].
|
max_workers : int, optional
|
Maximum number of workers to spawn; passed to
|
`concurrent.futures.ProcessPoolExecutor.__init__`.
|
[default: min(32, cpu_count() + 4)].
|
chunksize : int, optional
|
Size of chunks sent to worker processes; passed to
|
`concurrent.futures.ProcessPoolExecutor.map`. [default: 1].
|
lock_name : str, optional
|
Member of `tqdm_class.get_lock()` to use [default: mp_lock].
|
r )ÚProcessPoolExecutorr iè )Úwarnz
Iterable length %d > 1000 but `chunksize` is not set. This may seriously degrade multiprocess performance. Set `chunksize=1` or more.r )Ú
|
stacklevelr Úmp_lock)
|
r1 r4 Úmaxr& r Úwarningsr5 r r! r. )r( r) r* r4 Úlongest_iterable_lenr5 s r r r H s õ& 7Ù[¨ Ñ3ô #¤3¤{°IÓ#>Ó ?Ð Ø $Ò &Ý %Ù ð /à1EñFô ¨õ ,ð +Ñ%Ø!×&Ñ&Ó( Ø#, KÑ Ü Ð,¨bÐ L°9Ò LÀ Ñ LÐLr2 N)r )Ú__doc__Ú
|
contextlibr Úoperatorr Úosr Úautor r# Ústdr Ú
|
__author__Ú__all__r r. r
|
r © r2 r ú<module>rD sW ðñõ &Ý Ý å $Ý àk]Ð +
|
Ø Ð
|
'ð ò
|
&ó ð
|
&ò[ò2Ló$!Mr2
|
