+ IV-j~Rt^RIHt^RIHt^RIHt^RIHt ^RI H t RR./t RR .t ]RR l4tR tR tR tR#)z, Thin wrappers around `concurrent.futures`. )contextmanager) length_hint) cpu_count)tqdm) TqdmWarningz github.com/ casperdcl thread_map process_mapc#"\VRR4pT;'gVP4p\W1V4pVPV4VxVfV=R#VPV4R#5i)z>get (create if necessary) and then restore `tqdm_class`'s lock_lockN)getattrget_lockset_lockr ) tqdm_class lock_nameold_locklocks&& h/Volumes/fast/ai/experiments/ui-tars-smoke/.venv/lib/python3.14/site-packages/tqdm/contrib/concurrent.py ensure_lockrsdz7D1H  , ,z**,D 4D )D J  H%sA$A&c bVP4pRV9d\V^,4VR&VPR\4pVPR\ ^ \ 4^,44pVPR^4pVPRR4p\ WXR7;_uu_4p V!WePV 3R7;_uu_4p \V!V P!V.VO5RV/3/VB4uuR R R 4uuR R R 4# +'giM;iR R R 4R # +'giR #;i) z 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 max_workers chunksizer)r)r initializerinitargsN) copyrpop tqdm_autominrrrlistmap) PoolExecutorfn iterables tqdm_kwargskwargsrrrrlkexs &&*, r _executor_mapr)s   Ff%il3wL)4J**]CIK!O,DEK ;*I ;+I Z 5 5 k?R?R$&5**-/ 266"#Ny#NI#NYRXYZ** 6 5*** 6 5 5 5s$&D&C? * D? D D D. c,^RIHp\W0.VO5/VB#)av 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)]. )ThreadPoolExecutor)concurrent.futuresr+r))r#r$r%r+s&*, rrr6s6 + K) K{ KKc^RIHpV'dDRV9d=\\\V44pVR8d^RIHpV!RV,\^R7RV9dVP4pRVR&\W0.VO5/VB#) af 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]. )ProcessPoolExecutorri)warnzIterable length %d > 1000 but `chunksize` is not set. This may seriously degrade multiprocess performance. Set `chunksize=1` or more.) stacklevelrmp_lock) r,r/maxr!rwarningsr0rrr))r#r$r%r/longest_iterable_lenr0s&*, rr r Hs&7[ 3 #3{I#>? $ & % /1EF ,+%!&&( #, K , L9 L LLr-N)r)__doc__ contextlibroperatorrosrautorrstdr __author____all__rr)rr r-rr?sW& $k] +  ' & &[2L$!Mr-