U a+d@sLdZddlmZddlmZddlmZddgiZdgZ Gd dde Z d S) z, IO/concurrency helpers for `tqdm.contrib`. )deque)ThreadPoolExecutor)tqdmz github.com/Z casperdcl MonoWorkerc@s eZdZdZddZddZdS)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)rpoolrfutures)selfr =/tmp/pip-unpacked-wheel-tf4cttdx/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 lenmaxlenpopleftdonepopcancel appendleftr submit Exception tqdm_autowritestrappend)r funcargskwargsr ZrunningZwaitinger r r rs   zMonoWorker.submitN)__name__ __module__ __qualname____doc__rrr r r r r sN) r# collectionsrconcurrent.futuresrautorr __author____all__objectrr r r r s