o nN)j­ã@s`ddlZddlmZmZmZddlmZddlmZddgZGdd„de ƒZ Gdd„deƒZ dS) éN)ÚEventÚThreadÚcurrent_thread)Útime)ÚwarnÚTMonitorÚTqdmSynchronisationWarningc@seZdZdZdS)rzr tqdm multi-thread/-process errors which may cause incorrect nesting but otherwise no adverse effects N)Ú__name__Ú __module__Ú __qualname__Ú__doc__©r r ún/var/www/html/finance.cargoinsureonline.com/_shared/backend-venv/lib/python3.10/site-packages/tqdm/_monitor.pyr sc@sDeZdZdZiZdd„Zdd„Zdd„Zdd „Zd d „Z d d „Z dS)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. cCs`tj|ddd|_d|_||_||_|j dt¡|_ |j dt ¡ƒ|_ t   |j¡| ¡dS)NÚ tqdm_monitor)ÚnameTrrr)rÚ__init__ÚdaemonÚwokenÚtqdm_clsÚsleep_intervalÚ_testÚgetrÚ_timerÚ was_killedÚatexitÚregisterÚ_atexit_signalÚstart)Úselfrrr r rrs  zTMonitor.__init__cCs|j ¡dS)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)rÚset©rr r rr*szTMonitor._atexit_signalcCs$|j ¡|tƒur| ¡| ¡S©N)rrrÚjoinÚreportr r r rÚexit2s  z TMonitor.exitcCsdd„|jj ¡DƒS)NcSsg|] }t|dƒr|‘qS)Ústart_t)Úhasattr)Ú.0Úir r rÚ :s þz*TMonitor.get_instances..)rÚ _instancesÚcopyr r r rÚ get_instances8szTMonitor.get_instancescCsØ| ¡} ||_|j |j¡|j ¡rdS|j ¡H| ¡}| ¡}|D]'}|j ¡r6WdƒdS|j dkrL||j |j krLd|_ |j dd~q&|| ¡kr[t dtdd~Wdƒn1sfwYq)NTé)ÚnolockzOSet changed size during iteration (see https://github.com/tqdm/tqdm/issues/481)é)Ú stacklevel)rrrÚwaitrÚis_setrÚget_lockr,ÚminitersÚ last_print_tÚ maxintervalÚrefreshrr)rÚcur_tÚ instancesÚinstancer r rÚrun>s2   ù   þæõz TMonitor.runcCs |j ¡ Sr!)rr2r r r rr#gs zTMonitor.reportN) r r r r rrrr$r,r;r#r r r rrs   )) rÚ threadingrrrrÚwarningsrÚ__all__ÚRuntimeWarningrrr r r rÚs