yget (create if necessary) and then restore `tqdm_class`'s lock_lockN)getattrZget_lockset_lockr ) tqdm_class lock_nameZold_locklockr\/home/www/utuvibe.miabetepe.com/venv/lib/python3.12/site-packages/tqdm/contrib/concurrent.py ensure_locks   rc Os|j}d|kr,t|d|d<|jdt}|jdtdtd}|jdd}|jd d }t|d |W} |d|d |jd | f,} t|| j ||d||SWd QRXWd QRXd S)a 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]. Ztotalrr max_workers  chunksizerr Z initializerZinitargsN) copyrpop tqdm_autominrrrlistmap) Z PoolExecutorfn iterables tqdm_kwargskwargsrrrrZlkZexrrr _executor_maps  "r$cOs#ddlm}t||||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.futuresr%r$)r r!r"r%rrrr 6scOsddlm}|rjd|krjttt|}|dkrjddlm}|d|tddd |kr|j}d |d 1000 but `chunksize` is not set. This may seriously degrade multiprocess performance. Set `chunksize=1` or more. stacklevelrrZmp_lock) r&r'maxrrwarningsr(rrr$)r r!r"r'Zlongest_iterable_lenr(rrrr Hs     N)__doc__Z contextlibroperatorrosrautorrZstdr __author____all__rr$r r rrrrs