| 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� � �f � d Z ddlmZ ddlmZ ddlmZ ddlmZ ddgiZ
d gZ G d
� d e � � Z
d S ) z,
IO/concurrency helpers for `tqdm.contrib`.
� )�absolute_import)�deque)�ThreadPoolExecutor� )�tqdmz github.com/� casperdcl�
MonoWorkerc � � e Zd ZdZd� Zd� ZdS )r z�
Supports one running task and one waiting task.
The waiting task is the most recent submitted (others are discarded).
c �Z � t d�� � | _ t g d� � | _ d S )N� )� max_workersr )r �poolr �futures)�selfs �;/usr/lib/python3/dist-packages/tqdm/contrib/utils_worker.py�__init__zMonoWorker.__init__ s' � �&�1�5�5�5�� � �R��|�|�� � � � c � � | j }t |� � |j k rt|� � � }|� � � sLt |� � r(|� � � }|� � � |� |� � | j j |g|�R i |��}|�
|� � |S # t $ r,}t j
t |� � � � Y d}~dS d}~ww xY w)z;`func(*args, **kwargs)` may replace currently waiting task.N)r �len�maxlen�popleft�done�pop�cancel�
appendleftr �submit�append� Exception� tqdm_auto�write�str)r �func�args�kwargsr �running�waiting�es r r zMonoWorker.submit s � ��,�� �w�<�<�7�>� )� )� �o�o�'�'�G��<�<�>�>�
,��w�<�<� %� %�k�k�m�m�G��N�N�$�$�$��"�"�7�+�+�+� �&�d�i�&�t�=�d�=�=�=�f�=�=�G�
�N�N�7� #� #� #��N�� � $� $� $� �O�C��F�F� #� #� #� #� #� #� #� #� #����� $���s �C �
C8� !C3�3C8N)�__name__�
__module__� __qualname__�__doc__r r � r r r r s< � � � � � �� �$� $� $�� � � � r N)r+ �
__future__r � collectionsr �concurrent.futuresr �autor r �
__author__�__all__�objectr r, r r �<module>r4 s� ��� � '� &� &� &� &� &� � � � � � � 1� 1� 1� 1� 1� 1� $� $� $� $� $� $��k�]�
+�
� �.��� � � � �� � � � � r