Name	Size	Mode	Actions
bells.cpython-36.pyc	980	0644	editdlrm
concurrent.cpython-36.pyc	4187	0644	editdlrm
discord.cpython-36.pyc	4370	0644	editdlrm
itertools.cpython-36.pyc	943	0644	editdlrm
logging.cpython-36.pyc	3770	0644	editdlrm
slack.cpython-36.pyc	4406	0644	editdlrm
telegram.cpython-36.pyc	5327	0644	editdlrm
utils_worker.cpython-36.pyc	1478	0644	editdlrm
__init__.cpython-36.pyc	3042	0644	editdlrm

3 �Eg$�@s�dZd
dl
mZ
d
dlmZ
ddlmZ
ddlm Z
yd
dl mZ
Wnek rb


ddd �
ZYnXyd
d l mZ
WnBek r�


yd
d lmZ
Wnek r�


dd�ZYnXYnXd
d lZddg
i
ZddgZeddd�
�
Zdd�Zdd�Zdd�Zd S)z, Thin wrappers around `concurrent.futures`. �)
�absolute_import)
�contextmanager�)
�tqdm)
�TqdmWarning)
�length_hintcCs"yt|�
St
k r


|
SXd
S)z,Returns `len(it)`, falling back to `default`N)�len� TypeError)�it�default�r�A/usr/local/lib/python3.6/site-packages/tqdm/contrib/concurrent.pyrs


r)
� cpu_countc
Csd
S)N�rrrrr rs
rNzgithub.com/Z casperdcl� thread_map�process_map�ccsPt|d
d�}|p|j
�}t||
|�}|j|�

|V
|dkrB|`n |j|�

dS)z>get (create if necessary) and then restore `tqdm_class`'s lock�_lockN)�getattrZget_lock�set_lockr)� tqdm_class� lock_nameZold_lock�lockrrr �ensure_lock"s





rcOs
|j�}d
|kr t
|d�
|d
<|jdt�}|jdtdt�d��}|jdd�}|jd d �}t||d���} d|i
} tjdd �}|dkr�| j |j | f
d�
i}d|ko�dkn
s�|j |d�

|f| �
� } t|| j|
f
|�|�
f
|�
�
SQRXWd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]. �totalr
r�max_workers� r� chunksize�
rr)
rNr��)�initializer�initargs�)
r)rr )rr
)rr#) �copyr�pop� tqdm_auto�minrr�sys�version_info�updater�list�map)ZPoolExecutor�fn� iterables�tqdm_kwargs�kwargsrrrrZlk�pool_kwargs�sys_versionZmap_args�exrrr � _executor_map0s"














r4c
Osd
dlm
}
t||f|
�|�
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.futuresr5r4)r-r.r/r5rrr rOs
c
Osvd
dlm
}
|
rLd|krLttt|
��
}|dkrLd
dlm}
|d|tdd�
d |krd|j�}d |d <t ||f|
�|�
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]. lock_name : str, optional Member of `tqdm_class.get_lock()` to use [default: mp_lock]. r
)
�ProcessPoolExecutorri�)
�warnz�Iterable length %d > 1000 but `chunksize` is not set. This may seriously degrade multiprocess performance. Set `chunksize=1` or more.r)
� stacklevelrZmp_lock) r6r7�maxr,r�warningsr8rr$r4)r-r.r/r7Zlongest_iterable_lenr8rrr ras








)
r
)
r)�__doc__� __future__r� contextlibr�autorr&Zstdr�operatorr�ImportError�osr�multiprocessingr(� __author__�__all__rr4rrrrrr �s.