| Server IP : 54.37.205.81 / Your IP : 216.73.216.76 Web Server : nginx/1.22.1 System : Linux vps-249481fa 6.1.0-50-cloud-amd64 #1 SMP PREEMPT_DYNAMIC Debian 6.1.176-1 (2026-07-02) x86_64 User : debian ( 1000) PHP Version : 8.2.32 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : OFF | Sudo : ON | Pkexec : OFF Directory : /usr/lib/python3/dist-packages/tqdm/contrib/__pycache__/ |
Upload File : |
�
Em�c$ � � � d Z ddlmZ ddlmZ ddlmZ ddlm Z ddl
m Z n# e $ r dd�Z Y nw xY w dd l
mZ n!# e $ r dd lmZ n# e $ r d
� ZY nw xY wY nw xY wdd lZd d
giZddgZedd�� � Zd� Zd� Zd� Zd S )z,
Thin wrappers around `concurrent.futures`.
� )�absolute_import)�contextmanager� )�tqdm)� TqdmWarning)� length_hintc �F � t | � � S # t $ r |cY S w xY w)z,Returns `len(it)`, falling back to `default`)�len� TypeError)�it�defaults �9/usr/lib/python3/dist-packages/tqdm/contrib/concurrent.pyr r s6 � � ��r�7�7�N��� � � ��N�N�N� ���s � � � )� cpu_countc � � dS )N� � r � r r r s � ��1r Nz github.com/� casperdcl�
thread_map� process_map� c # �� K � t | dd� � }|p| � � � }t |||� � }| � |� � |V � |�| `dS | � |� � dS )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 r � ensure_lockr! " s� � � � � �z�7�D�1�1�H� � ,�z�*�*�,�,�D� �4��D� )� )�D����� � � �
�J�J�J��� � � � ����H�%�%�%�%�%r c � � |� � � }d|vrt |d � � |d< |� dt � � }|� dt dt � � dz � � � � }|� dd� � }|� d d
� � }t
||� � � 5 } d|i}
t j d d
� } | dk r |
� |j
| f�� � i } d| cxk rdk sn | � |�� � | di |
��5 }
t | |
j |g|�R i | ��fi |��� � cd d d � � cd d d � � S # 1 swxY w Y d d d � � d S # 1 swxY w Y d 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� r r )r Nr )� � )� initializer�initargs)r( r )r( � )r& r )
�copyr �pop� tqdm_auto�minr r! �sys� version_info�updater �list�map)� PoolExecutor�fn� iterables� tqdm_kwargs�kwargsr r$ r& r �lk� pool_kwargs� sys_version�map_args�exs r �
_executor_mapr@ 0 s} � � �
�
�
�
�F��f� � �%�i��l�3�3��w�����L�)�4�4�J��*�*�]�C��I�K�K�!�O�,D�,D�E�E�K��
�
�;��*�*�I��
�
�;��+�+�I� �Z�9� 5� 5� 5�
R��$�k�2� ��&�r��r�*� � �&� � � � � �:�+>�"�� � O� O� O���� �,�,�,�,�f�,�,�,�,� �O�O�i�O� 0� 0� 0�
�\�
(�
(�K�
(�
(� R�B��
�
�6�2�6�"�#E�y�#E�#E�#E�H�#E�#E�P�P��P�P�Q�Q� R� R� R� R� R� R� R�
R�
R�
R�
R�
R�
R�
R�
R� R� R� R� R���� R� R� R� R� R�
R�
R�
R�
R�
R�
R�
R�
R�
R�
R�
R�
R����
R�
R�
R�
R�
R�
Rs7 �<A+E>�'%E%� E>�%E) �)E>�,E) �-E>�>F�Fc �0 � ddl m} t || g|�R i |��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.futuresrB r@ )r7 r8 r9 rB s r r r O s7 � � 6�5�5�5�5�5� �+�R� K�)� K� K� K�{� K� K�Kr c � � ddl m} |rHd|vrDt t t |� � � � }|dk r ddlm} |d|z t d�� � d |vr|� � � }d
|d < t || g|�R i |��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 )�ProcessPoolExecutorr& i� )�warnz�Iterable length %d > 1000 but `chunksize` is not set. This may seriously degrade multiprocess performance. Set `chunksize=1` or more.r )�
stacklevelr �mp_lock)
rC rE �maxr5 r �warningsrF r r- r@ )r7 r8 r9 rE �longest_iterable_lenrF s r r r a s� � �& 7�6�6�6�6�6�� ,�[� �3�3� #�3�{�I�#>�#>� ?� ?� � �$� &� &� %� %� %� %� %� %� �D� /�1E�F� ��
,�
,�
,�
,� �+�%�%�!�&�&�(�(� �#,� �K� � �,�b� L�9� L� L� L� � L� L�Lr )r )r )�__doc__�
__future__r �
contextlibr �autor r/ �stdr �operatorr � ImportError�osr �multiprocessingr1 �
__author__�__all__r! r@ r r r r r �<module>rW s� ��� � '� &� &� &� &� &� %� %� %� %� %� %� $� $� $� $� $� $� � � � � � ��$�$�$�$�$�$�$��� � � �� � � � � ������ � � � � � � ��� � � ��-�-�-�-�-�-�-�� � � � � � � � � ����������� �
�
�
��k�]�
+�
� � �
'�� �
&�
&�
&� � �
&� R� R� R�>L� L� L�$!M� !M� !M� !M� !Ms? �# � /�/�: �A� A�A�A�A�A�A�A