o rh @sdZddlmZddlmZddlmZddlmZzddl m Z Wne y0dddZ Ynwzdd l m Z Wne yXzdd lm Z Wn e yUd d Z YnwYnwdd lZd dgiZddgZddZddZddZd S)z, Thin wrappers around `concurrent.futures`. )absolute_import) TqdmWarning)tqdm)deepcopy) length_hintcCs"zt|WSty|YSw)z,Returns `len(it)`, falling back to `default`)len TypeError)itdefaultr I/var/www/html/env/lib/python3.10/site-packages/tqdm/contrib/concurrent.pyr s   r) cpu_countcCsdS)Nr r r r r r sr Nz github.com/ casperdcl thread_map process_mapc Ost|}d|vrt|d|d<|dt}|dtdtd}|dd}t|d }tjd d } | d krC|j |j | fd i} d| krOdksVn| j |d|di|} t || j |g|Ri| fi|Wd S1s|wYd S)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]. totalr tqdm_class max_workers r chunksize)rN)) initializerinitargs)rr)r)rr )rrpop tqdm_autominr dictsys version_infoupdateset_lockget_locklistmap) PoolExecutorfn iterables tqdm_kwargskwargsrrr pool_kwargs sys_versionmap_argsexr r r _executor_maps,      $r2cOs$ddlm}t||g|Ri|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.futuresr3r2)r*r+r,r3r r r r<s cOsdddlm}|r&d|vr&ttt|}|dkr&ddlm}|d|tddt||g|Ri|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]. r)ProcessPoolExecutorri)warnzIterable length %d > 1000 but `chunksize` is not set. This may seriously degrade multiprocess performance. Set `chunksize=1` or more.r) stacklevel) r4r5maxr(rwarningsr6rr2)r*r+r,r5longest_iterable_lenr6r r r rNs   )r)__doc__ __future__rrr tqdm.autorcopyroperatorr ImportErrorosr multiprocessingr" __author____all__r2rrr r r r s4