BjlddlZddlmZmZmZddlmZddlmZddgZGdde Z GddeZ y) N)EventThreadcurrent_thread)time)warnTMonitorTqdmSynchronisationWarningceZdZdZy)r zr tqdm multi-thread/-process errors which may cause incorrect nesting but otherwise no adverse effects N)__name__ __module__ __qualname____doc__K/root/workspace/ytshorts/venv/lib/python3.12/site-packages/tqdm/_monitor.pyr r src8eZdZdZiZdZdZdZdZdZ dZ y) ra^ Monitoring thread for tqdm bars. Monitors if tqdm bars are taking too much time to display and readjusts miniters automatically if necessary. Parameters ---------- tqdm_cls : class tqdm class to use (can be core tqdm or a submodule). sleep_interval : float Time to sleep between monitoring checks. cftj|dd|_d|_||_||_|j jdt|_ |j jdt|_ tj|j|jy)N tqdm_monitor)nameTrrr)r__init__daemonwokentqdm_clssleep_interval_testgetr_timer was_killedatexitregister_atexit_signalstart)selfrrs rrzTMonitor.__init__sy>2    ,ZZ^^FD1 8$**..%8:++, rc8|jjy)z Non-joining shutdown signal. Avoids deadlocks at interpreter exit from other threads, dead forks, etc. This daemon thread is auto-reaped on shutdown without needing a join. N)rsetr#s rr!zTMonitor._atexit_signal*s rc|jj|tur|j|j SN)rr%rjoinreportr&s rexitz TMonitor.exit2s2  ~' ' IIK{{}rc|jjjDcgc]}t|dr|c}Scc}w)Nstart_t)r _instancescopyhasattr)r#is r get_instanceszTMonitor.get_instances8s>==3388:*a1i(* **s?c|j} ||_|jj|j|jj ry|j j5|j}|j}|D]k}|jj r dddy|jdkDr5||jz |jk\rd|_ |jd~m||jk7rtdtd~ddd"#1swY xYw)NT)nolockzOSet changed size during iteration (see https://github.com/tqdm/tqdm/issues/481)) stacklevel)rrrwaitris_setrget_lockr2miniters last_print_t maxintervalrefreshrr )r#cur_t instancesinstances rrunz TMonitor.run>s( DJ OO !4!4 5%%''')   ..0 )!H--/  !))A-"X%:%::x?S?SS-.) (((5 !!" 2 2 44J3C5   s3AD4=A-D44D=c8|jj Sr()rr9r&s rr*zTMonitor.reportgs??))+++rN) r r r rrrr!r+r2rBr*rrrrrs-  E  * 'R,r) r threadingrrrrwarningsr__all__RuntimeWarningr rrrrrHs9 33 3 4X,vX,r