Ë
    $Æ%h·  ã                   óR   — d Z ddlmZ ddlmZ ddlmZ ddgiZdgZ	 G d	„ de
«      Zy
)z,
IO/concurrency helpers for `tqdm.contrib`.
é    )Údeque)ÚThreadPoolExecutoré   )Útqdmzgithub.com/Ú	casperdclÚ
MonoWorkerc                   ó   — e Zd ZdZd„ Zd„ Zy)r   zƒ
    Supports one running task and one waiting task.
    The waiting task is the most recent submitted (others are discarded).
    c                 óH   — t        d¬«      | _        t        g d«      | _        y )Né   )Úmax_workersr   )r   Úpoolr   Úfutures)Úselfs    úW/var/www/skyplay_api_hub/venv/lib/python3.12/site-packages/tqdm/contrib/utils_worker.pyÚ__init__zMonoWorker.__init__   s   € Ü&°1Ô5ˆŒ	Ü˜R “|ˆ�ó    c                 óÒ  — | j                   }t        |«      |j                  k(  r\|j                  «       }|j	                  «       s<t        |«      r |j                  «       }|j                  «        |j                  |«       	  | j                  j                  |g|¢­i |¤Ž}|j                  |«       |S # t        $ r(}t        j                  t        |«      «       Y d}~yd}~ww xY 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   zMonoWorker.submit   s·   € à—,‘,ˆÜˆw‹<˜7Ÿ>™>Ò)Ø—o‘oÓ'ˆGØ—<‘<”>Ü�w”<Ø%Ÿk™k›m�GØ—N‘NÔ$Ø×"Ñ" 7Ô+ð	Ø&�d—i‘i×&Ñ& tÐ=¨dÒ=°fÑ=ˆGð �N‰N˜7Ô#ØˆNøô	 ò 	$Ü�O‰OœC ›F×#Ñ#ûð	$ús   Â B5 Â5	C&Â>C!Ã!C&N)Ú__name__Ú
__module__Ú__qualname__Ú__doc__r   r   © r   r   r   r      s   „ ñò$ór   N)r*   Úcollectionsr   Úconcurrent.futuresr   Úautor   r   Ú
__author__Ú__all__Úobjectr   r+   r   r   ú<module>r2      s4   ðñõ Ý 1å $à˜k˜]Ð+€
Øˆ.€ô�õ r   