a Lªf·ã@sLdZddlmZddlmZddlmZddgiZdgZ Gd d„de ƒZ d S) z, IO/concurrency helpers for `tqdm.contrib`. é)Údeque)ÚThreadPoolExecutoré)Útqdmz github.com/Z casperdclÚ MonoWorkerc@s eZdZdZdd„Zdd„ZdS)rzƒ Supports one running task and one waiting task. The waiting task is the most recent submitted (others are discarded). cCstdd|_tgdƒ|_dS)Né)Ú max_workersr)rÚpoolrÚfutures)Úself©r úR/var/www/ai-form-bot/venv/lib/python3.9/site-packages/tqdm/contrib/utils_worker.pyÚ__init__s zMonoWorker.__init__c Osª|j}t|ƒ|jkrF| ¡}| ¡sFt|ƒr<| ¡}| ¡| |¡z|jj |g|¢Ri|¤Ž}Wn2t y–}zt   t |ƒ¡WYd}~nd}~00| |¡|SdS)z;`func(*args, **kwargs)` may replace currently waiting task.N)r ÚlenÚmaxlenÚpopleftÚdoneÚpopÚcancelÚ appendleftr ÚsubmitÚ ExceptionÚ tqdm_autoÚwriteÚstrÚappend)r ÚfuncÚargsÚkwargsr ÚrunningZwaitingÚer r r rs $ zMonoWorker.submitN)Ú__name__Ú __module__Ú __qualname__Ú__doc__rrr r r r r sN) r$Ú collectionsrÚconcurrent.futuresrÚautorrÚ __author__Ú__all__Úobjectrr r r r Ús