K iRdZddlmZddlmZddlmZddgiZdgZ Gd de Z y ) z, IO/concurrency helpers for `tqdm.contrib`. )deque)ThreadPoolExecutor)tqdmz github.com/ casperdcl MonoWorkerceZdZdZdZdZy)rz Supports one running task and one waiting task. The waiting task is the most recent submitted (others are discarded). cHtd|_tgd|_y)N) max_workersr)rpoolrfutures)selfs _/mnt/ssd/data/python-lab/Trading/venv/lib/python3.12/site-packages/tqdm/contrib/utils_worker.py__init__zMonoWorker.__init__s&15 R| c|j}t||jk(r\|j}|j s> )oo'G<<>w<%kkmGNN$""7+ &dii&&t=d=f=G NN7 #N  $ OOCF # # $s B55 C&>C!!C&N)__name__ __module__ __qualname____doc__rrrrrr s$rN) r* collectionsrconcurrent.futuresrautorr __author____all__objectrr+rrr2s41$k] + .r