o j@sJdZddlmZddlmZddlmZddgiZdgZ Gd ddZ d S) z, IO/concurrency helpers for `tqdm.contrib`. )deque)ThreadPoolExecutor)tqdmz github.com/ 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 /root/aizidognhua/tmp/workspace/projects/ec89d86c-575f-41c9-af57-ac45cbdbf775/venv/lib/python3.10/site-packages/tqdm/contrib/utils_worker.py__init__s zMonoWorker.__init__c Os|j}t||jkr#|}|s#t|r|}|||z|jj |g|Ri|}Wnt yL}zt t |WYd}~dSd}~ww|||S)z;`func(*args, **kwargs)` may replace currently waiting task.N)r lenmaxlenpopleftdonepopcancel appendleftr submit Exception tqdm_autowritestrappend)r funcargskwargsr runningwaitinger r rrs   zMonoWorker.submitN)__name__ __module__ __qualname____doc__rrr r r rr s N) r& collectionsrconcurrent.futuresrautorr __author____all__rr r r rs