File: //usr/local/lib/python3.10/dist-packages/tqdm/__pycache__/_monitor.cpython-310.pyc
o
���gs � @ s` d dl Z d dlmZmZmZ d dlmZ d dlmZ ddgZG dd� de �Z
G dd� de�Z dS ) � N)�Event�Thread�current_thread)�time)�warn�TMonitor�TqdmSynchronisationWarningc @ s e Zd ZdZdS )r zhtqdm multi-thread/-process errors which may cause incorrect nesting
but otherwise no adverse effectsN)�__name__�
__module__� __qualname__�__doc__� r
r
�8/usr/local/lib/python3.10/dist-packages/tqdm/_monitor.pyr s c @ s< e Zd ZdZi Zdd� Zdd� Zdd� Zdd � Zd
d � Z d S )
r a^
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.
c C s\ t �| � d| _d| _|| _|| _| j�dt�| _ | j�dt
�� | _ t �
| j� | �� d S )NTr r r )r �__init__�daemon�woken�tqdm_cls�sleep_interval�_test�getr �_timer �
was_killed�atexit�register�exit�start)�selfr r r
r
r r s
zTMonitor.__init__c C s$ | j �� | t� ur| �� | �� S �N)r �setr �join�report�r r
r
r r ) s
z
TMonitor.exitc C s dd� | j j�� D �S )Nc S s g | ] }t |d �r|�qS )�start_t)�hasattr)�.0�ir
r
r �
<listcomp>1 s
�z*TMonitor.get_instances.<locals>.<listcomp>)r �
_instances�copyr! r
r
r �
get_instances/ s zTMonitor.get_instancesc C s� | � � } || _| j�| j� | j�� rd S | j�� �H | � � }| �� }|D ]'}| j�� r6 W d � d S |j dkrL||j
|j krLd|_ |j dd� ~q&|| �� kr[t
dtdd� ~W d � n1 sfw Y q)NT� )�nolockzOSet changed size during iteration (see https://github.com/tqdm/tqdm/issues/481)� )�
stacklevel)r r r �waitr �is_setr �get_lockr) �miniters� last_print_t� maxinterval�refreshr r )r �cur_t� instances�instancer
r
r �run5 s2
�
� ��z TMonitor.runc C s | j �� S r )r r/ r! r
r
r r ^ s zTMonitor.reportN)
r r
r r r r r r) r8 r r
r
r
r r s )) r � threadingr r r r �warningsr �__all__�RuntimeWarningr r r
r
r
r �<module> s