codekingpro/portable-devtools
114k
1�
2 �j� � �P � S r SSKJr SSKJr SSKJr SS/0rS/r " S S5 r3g4) z,5IO/concurrency helpers for `tqdm.contrib`.6� )�deque)�ThreadPoolExecutor� )�tqdmz github.com/� casperdcl�7MonoWorkerc �$ � \ rS rSrSrS rS rSrg)r �
zw8Supports one running task and one waiting task.9The waiting task is the most recent submitted (others are discarded).10c �B � [ SS9U l [ / S5 U l g )N� )� max_workersr )r �poolr �futures)�selfs �_D:\code\apps\devtools\python\user_packages\Python313\site-packages\tqdm/contrib/utils_worker.py�__init__�MonoWorker.__init__ s � �&�1�5�� � �R��|�� � c �� � U R n[ U5 UR :X af UR 5 nUR 5 ( dA [ U5 ( a UR 5 nUR
5 UR U5 U R R " U/UQ70 UD6nUR U5 U$ ! [ a) n[ R " [ U5 5 SnAgSnAff = f)z;`func(*args, **kwargs)` may replace currently waiting task.N)r �len�maxlen�popleft�done�pop�cancel�11appendleftr �submit�append� Exception� tqdm_auto�write�str)r �func�args�kwargsr �running�waiting�es r r �MonoWorker.submit s� � ��,�,�� �w�<�7�>�>� )� �o�o�'�G��<�<�>�>��w�<�<� %�k�k�m�G��N�N�$��"�"�7�+� ��i�i�&�&�t�=�d�=�f�=�G�
�N�N�7� #��N�� � $� �O�O�C��F� #� #�� $�s �
C � 12C3�13 C.�.C3)r r N)�__name__�14__module__� __qualname__�__firstlineno__�__doc__r r �__static_attributes__� r r r r
s � ��$�r N) r. � collectionsr �concurrent.futuresr �autor r �15__author__�__all__r r0 r r �<module>r6 s2 ��� � 1� $��k�]�
+�16� �.��� r