+ j&Rt^RIt^RIHt^RIHt^RIHt^RI H t RR./t .ROt !RR 4t ]RR l4tR tR tRRRRR^RR R]RRRRRRRR/ RltRtRtRR/RltR#)z, Thin wrappers around `concurrent.futures`. N)contextmanager length_hint)tqdm) TqdmWarningz github.com/ casperdclc^a]tRt^toRt^RIHt^RIHt Rt R Rlt Rt Rt RtR tVtR #) _InterpreterLockz3Reentrant lock backed by a cross-interpreter queue.) get_ident) monotoniccR^RIHpWnV!4VnRVn^VnR#))RLockN) threadingr_queue_lock_owner_depth)selfqueuers&& X/home/luca/screen-checking/.venv/lib/python3.14/site-packages/tqdm/contrib/concurrent.py__init___InterpreterLock.__init__s!# W   c^RIHpVP4pVR8XdVPP V4pMVPP W4pV'gR#VP 'dV;P ^, unR#V'gVP P4MfVR8XdVP P4MD\^W P4V, , 4pVP PVR7VP4Vn ^VnR# TdTPP4R#i;i)r )EmptyFT)timeout) rr_timeracquirerr get_nowaitgetmaxreleaser r)rblockingrrstartacquired remainings&&& rr_InterpreterLock.acquires  b=zz))(3Hzz))(get (create if necessary) and then restore `tqdm_class`'s lockrN)getattrget_lockset_lockr) tqdm_class lock_namelockold_locks&&& r ensure_lockrHGsiz7D1H |00:..0 4D )D J  H%s A*A A*c R\P: RVP: RVPP R4: RV: R2 p\ V33#)zGReturn an initializer which bootstraps the parent import path and lock.zimport sys sys.path[:] = z from concurrent import interpreters from importlib import import_module from tqdm.contrib.concurrent import _InterpreterLock tqdm_class = import_module(z) for name in .z: tqdm_class = getattr(tqdm_class, name) tqdm_class.monitor_interval = 0 tqdm_class.set_lock(_InterpreterLock(interpreters.Queue(z))))syspathr7r8splitexec)rD lock_queue_idcodes&& r_get_interpreter_initrQVsk  %&'1&;&;%>?!..44S9<=CDQBSSV X  $=rc2a\V3RlV4^R7#)z+min(map(length_hint, iterables), default=0)c3R<"TFp\VR4;o^8gKSxK R#5i)Nrr).0itns& r _min_map_len..hs&IIb{2r/B*B!q)HIs' ')default)min) iterablesrWs&@r _min_map_lenr]fs IIIST UUr max_workersr chunksizerErD smoothinggr _initializer _initargsc aaV P4p RV 9d\V 4V R&/pRV 9dV PR4VR&/pRF pVV 9gK V PV4VV&K" RpV R,'dPRV 9dI^RIHpT;'g#\^ V!4;'g^^,4pV R,V8dVV R&Rp\WeVR7;_uu_4pV fVPp V3p V!RR VR V R V /VB;_uu_4pV!RR V/V B;_uu_4oVeRSn VPoVV3R lpVVn \VP!V.V O5RVRV/VB4uuRRR4uuRRR4uuRRR4# \ d ^RIHpELi;i +'giM;iRRR4M +'giM;iRRR4R# +'giR#;i)z Implementation of `thread_map`, `process_map` and `interpreter_map`. Parameters ---------- max_workers : int timeout : int buffersize : int Requires Python>=3.14. thread_name_prefix : str max_tasks_per_child : int mp_context : str total buffersizeNminiters)process_cpu_count) cpu_countT)rErFr^ initializerinitargsr`cB<S!V/VBpVPV3Rl4V#)c$<SP4#r/)update)_pbars&r4_executor_map..patchsubmit..s DKKMr)add_done_callback)argskwargsfut orisubmitros*, r patchsubmit"_executor_map..patchsubmits&#T4V4C))*ABJrrr_)thread_name_prefixmax_tasks_per_child mp_context)copyr]poposrg ImportErrorrhr[rHrCdynamic_miniterssubmitlistmap) PoolExecutorfnr^rr_rErDr`rrarbr\ tqdm_kwargsrt map_kwargs pool_kwargskrrh rough_maxlkexrwrvros&&$$$$$$$$$*, @@r _executor_maprks$   Ff&y1wJv#)::l#; < K H ;#ZZ]KNI g:V3 % 9 BB3rIK,<,<1+A#B '?Y &!*F: #  Z5 A AR  %..LI )k)|)V_)')),.:i:6::d#/,0D)II ( BFFX"X,3X?HXLVXY;:)) B A % $ $ %;::)))) B A A AsUF"*G F; AF ' F; 1 GFF F.)F; 2 G; G G G) c,^RIHp\W0.VO5/VB#)a` Equivalent of `list(map(fn, *iterables))` driven by `concurrent.futures.ThreadPoolExecutor`. Parameters ---------- max_workers : int, optional Maximum number of workers to spawn; passed to `concurrent.futures.ThreadPoolExecutor`. thread_name_prefix : str, optional Passed to `concurrent.futures.ThreadPoolExecutor` [default: '']. timeout : int or float, optional Seconds to wait before raising `TimeoutError` if `__next__` is called and the result isn't available. [default: None]. buffersize : int, optional Requires Python>=3.14 [default: None]. tqdm_class : optional `tqdm` class to use for bars [default: tqdm.auto.tqdm]. smoothing : float, optional Passed to `tqdm_class`; the [default: 0] is average (due to erratic update frequency). lock_name : str, optional Member of `tqdm_class.get_lock()` to use [default: '']. )ThreadPoolExecutor)concurrent.futuresrr)rr\rrs&*, r thread_maprs.6 + K) K{ KKrc ^RIHp^RIHpVP 4pVP R4VP R\4p\WeP4wrx\W@.VO5R\V4RVRV/VB#)aB Equivalent of `list(map(fn, *iterables))` driven by `concurrent.futures.InterpreterPoolExecutor` (Python 3.14+). Parameters ---------- Same as `thread_map`. Notes ----- `fn`, its arguments, and its return values must be pickleable. Worker progress bars using the same `tqdm_class` share a cross-interpreter write lock. ) interpreters)InterpreterPoolExecutorNrDrrarb) concurrentrrr create_queuer+r! tqdm_autorQidrr ) rr\rrr lock_queuerDrirjs &*, rinterpreter_maprs(:**,JNN4y9J1*mmLK  E&/ E7G 7S E  E,4 E8C EErmp_lockc^RIHpV'd6RV9d/\V4pVR8d^RIHpV!RV,\ ^R7\ W@.VO5RV/VB#)a Equivalent of `list(map(fn, *iterables))` driven by `concurrent.futures.ProcessPoolExecutor`. Parameters ---------- max_workers : int, optional Maximum number of workers to spawn; passed to `concurrent.futures.ProcessPoolExecutor`. timeout : int or float, optional Seconds to wait before raising `TimeoutError` if `__next__` is called and the result isn't available. [default: None]. chunksize : int, optional Approximate size of chunks sent to worker processes; passed to `concurrent.futures.ProcessPoolExecutor.map`. [default: 1]. buffersize : int, optional Requires Python>=3.14 [default: None]. max_tasks_per_child : int, optional Maximum number of tasks a worker process can complete before being replaced with a new process; passed to `concurrent.futures.ProcessPoolExecutor`. mp_context : multiprocessing.BaseContext, optional Multiprocessing context to use, e.g. `multiprocessing.get_context('fork')`. lock_name : str, optional Member of `tqdm_class.get_lock()` to use [default: mp_lock]. tqdm_class : optional `tqdm` class to use for bars [default: tqdm.auto.tqdm]. smoothing : float, optional Passed to `tqdm_class`; the [default: 0] is average (due to erratic update frequency). )ProcessPoolExecutorr_i)warnzIterable length %d > 1000 but `chunksize` is not set. This may seriously degrade multiprocess performance. Set `chunksize=1` or more.) stacklevelrE)rrr]warningsrrr)rrEr\rrshortest_iterable_lenrs&$*, r process_maprsd:7[ 3!-Y 7 4 ' % /1FG , , a9 a aU` aar)rrr)r?N)r:rK contextlibroperatorrautorrstdr __author____all__r rHrQr]rrrrr|rrrs % $k] + :55p & &  V 9Y.29Y<@9YLM9YY[9Y9Y$'9Y/39YBF9YRV9YxL6E2(b)(br