+
    Bi                     T    R t ^ RIHt ^ RIHt ^RIHt RR./tR.t	 ! R R]
4      tR# )	z,
IO/concurrency helpers for `tqdm.contrib`.
)deque)ThreadPoolExecutor)tqdmzgithub.com/	casperdcl
MonoWorkerc                   0   a  ] tR t^t o RtR tR tRtV tR# )r   zw
Supports one running task and one waiting task.
The waiting task is the most recent submitted (others are discarded).
c                J    \        ^R7      V n        \        . ^4      V n        R# )   )max_workersN)r   poolr   futures)selfs   &>/usr/lib/python3.14/site-packages/tqdm/contrib/utils_worker.py__init__MonoWorker.__init__   s    &15	R|    c                   V P                   p\        V4      VP                  8X  di   VP                  4       pVP	                  4       '       gC   \        V4      '       d!   VP                  4       pVP                  4        VP                  V4        V P                  P                  ! V.VO5/ VB pVP                  V4       V#   \         d+   p\        P                  ! \        T4      4        Rp?R# Rp?ii ; i)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   MonoWorker.submit   s    ,,w<7>>)oo'G<<>>w<<%kkmGNN$""7+	ii&&t=d=f=G NN7#N	  	$OOCF##	$s    C C8C33C8)r   r   N)	__name__
__module____qualname____firstlineno____doc__r   r   __static_attributes____classdictcell__)__classdict__s   @r   r   r      s     $ r   N)r+   collectionsr   concurrent.futuresr   autor   r   
__author____all__objectr    r   r   <module>r6      s4     1 $k]+
. r   