+
    Bi                     ~    R t ^ RIHt ^ RIHt ^ RIHt ^RIHt	 ^RI
Ht RR./tRR	.t]RR
 l4       tR tR tR tR# )z,
Thin wrappers around `concurrent.futures`.
)contextmanager)length_hint)	cpu_count)tqdm)TqdmWarningzgithub.com/	casperdcl
thread_mapprocess_mapc              #     "   \        V RR4      pT;'       g    V P                  4       p\        W1V4      pV P                  V4       Vx  Vf   V =R# V P                  V4       R# 5i)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   &&  </usr/lib/python3.14/site-packages/tqdm/contrib/concurrent.pyensure_lockr      sd      z7D1H,,z**,D4D)D
JH%s   A$A&c                b   VP                  4       pRV9  d   \        V^ ,          4      VR&   VP                  R\        4      pVP                  R\	        ^ \        4       ^,           4      4      pVP                  R^4      pVP                  RR4      p\        WXR7      ;_uu_ 4       p	V ! WeP                  V	3R7      ;_uu_ 4       p
\        V! V
P                  ! V.VO5RV/ 3/ VB 4      uuR	R	R	4       uuR	R	R	4       #   + '       g   i     M; i R	R	R	4       R	#   + '       g   i     R	# ; 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   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3wL)4J**]CIK!O,DEK

;*I

;+I	Z	5	5k?R?R$&5* *-/
266"#Ny#NI#NYRXYZ* * 
6	5* * * 
6	5	5	5s$   &D&C?	*
D?D
DD.	c                ,    ^ RI Hp \        W0.VO5/ VB # )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   &*, r   r   r   6   s     6+K)K{KK    c                    ^ RI Hp V'       dD   RV9  d=   \        \        \        V4      4      pVR8  d   ^ RIHp V! RV,          \        ^R7       RV9  d   VP                  4       pRVR&   \        W0.VO5/ VB # )	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].
)ProcessPoolExecutorr   i  )warnzIterable length %d > 1000 but `chunksize` is not set. This may seriously degrade multiprocess performance. Set `chunksize=1` or more.)
stacklevelr   mp_lock)
r,   r/   maxr!   r   warningsr0   r   r   r)   )r#   r$   r%   r/   longest_iterable_lenr0   s   &*,   r   r	   r	   H   s    & 7[3  #3{I#>?$&% /1EF , +%!&&(#,K ,L9LLLr-   N)r   )__doc__
contextlibr   operatorr   osr   autor   r   stdr   
__author____all__r   r)   r   r	    r-   r   <module>r?      sW    &    $ k]+

' 
& 
&[2L$!Mr-   