U Î~fh·ã@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 ú=/tmp/pip-unpacked-wheel-q5zzfsrg/tqdm/contrib/utils_worker.pyÚ__init__s zMonoWorker.__init__c Os¢|j}t|ƒ|jkrF| ¡}| ¡sFt|ƒr<| ¡}| ¡| |¡z|jj |f|ž|Ž}Wn0t k rŽ}zt   t |ƒ¡W5d}~XYnX| |¡|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 ZrunningZwaitingÚ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