Ei|SrSSKJr SSKJr SSKJr SSKJr SSK J r SS /0r S S /r \SS j5rS rSrSrg)z, Thin wrappers around `concurrent.futures`. )contextmanager) length_hint) cpu_count)tqdm) TqdmWarningz github.com/ casperdcl thread_map process_mapc## [USS5nU=(d UR5n[X1U5nURU5 Uv UcU?gURU5 g7f)z>get (create if necessary) and then restore `tqdm_class`'s lock_lockN)getattrget_lockset_lockr ) tqdm_class lock_nameold_locklocks T/home/mande/repo/quber/.venv/lib/python3.13/site-packages/tqdm/contrib/concurrent.py ensure_lockrsaz7D1H  ,z**,D 4D )D J  H%sA A"c UR5nSU;a[US5US'URS[5nURS[ S[ 5S-55nURSS5nURS S 5n[ XXS 9n U"XeRU 4S 9n [U"U R"U/UQ7SU0640UD65sS S S 5 sS S S 5 $!,(df  O=fS S S 5 g !,(df  g =f)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]. totalrr 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 k?R?R$&5*-/ 266"#Ny#NI#NYRXYZ** 6 5*** 6 5 5s$C9%&C C9 C, (C99 Dc,SSKJn [X0/UQ70UD6$)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)]. r)ThreadPoolExecutor)concurrent.futuresr0r.)r(r)r*r0s rr r 6s6 + K) K{ KKcSSKJn U(a:SU;a4[[[U55nUS:aSSKJn U"SU-[SS9 S U;aUR5nS US '[X0/UQ70UD6$) 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]. r)ProcessPoolExecutorri)warnzIterable length %d > 1000 but `chunksize` is not set. This may seriously degrade multiprocess performance. Set `chunksize=1` or more.r) stacklevelrmp_lock) r1r4maxr&rwarningsr5rr!r.)r(r)r*r4longest_iterable_lenr5s rr r Hs&7[ 3 #3{I#>? $ & % /1EF ,+%!&&( #, K , L9 L LLr2N)r)__doc__ contextlibroperatorrosrautorr#stdr __author____all__rr.r r r2rrDsW& $k] +  ' & &[2L$!Mr2