File: //usr/local/lib/python3.9/site-packages/celery/utils/__pycache__/timer2.cpython-39.pyc
a
X>h� � @ s� d Z ddlZddlZddlZddlmZ ddlmZ ddlm Z ddl
m Z m Z m
Z
mZmZ ddlmZ ddlmZ dd lmZmZ ej�d
�Zd ZG d d
� d
ej�ZdS )z�Scheduler for Python functions.
.. note::
This is used for the thread-based worker only,
not for amqp/redis/sqs/qpid where :mod:`kombu.asynchronous.timer` is used.
� N)�count)� TIMEOUT_MAX)�sleep)�Any�Callable�Iterator�Optional�Tuple)�Entry)�Timer)�logger� to_timestamp� TIMER_DEBUG)r
�Scheduler r
c s� e Zd ZU dZeZeZdZeed< dZ e
e e gdf ed< e
d�Ze
ed< erfeedd�� fd d
� Zd6e
e e
e egdf e
e e gdf e
e d gdf e
e edd �� fd d
�
Ze
e d�dd�Ze ZZdd�dd�Zdd�dd�Zdd�dd�Zeeeed�dd�Zd7ee e
e ed�dd �Z eeed�d d �Z eeed�d d �Z eeed�d!d"�Z eeed�d#d$�Z!d8e e dd&�d'd(�Z"edd)�d*d+�Z#dd�d,d-�Z$ed�d.d/�Z%e d�d0d1�Z&ed�d2d3�Z'e'Z(e)e*d�d4d5��Z+� Z,S )9r z^Timer thread.
Note:
This is only used for transports not supporting AsyncIO.
F�runningN�on_tick� � _timer_count)�args�kwargs�returnc s. dd l }td� |�� t� j|i |�� d S )Nr z- Timer starting)� traceback�print� print_stack�super�start)�selfr r r �� __class__� �=/usr/local/lib/python3.9/site-packages/celery/utils/timer2.pyr ( s z Timer.start)�schedule�on_errorr �on_start� max_intervalr r c sx |p| j ||d�| _|| _|p"| j| _t� �� t�� | _t�� | _ t�
� | _ t� | j �| _
d| _dt| j�� �| _d S )N)r" r$ TzTimer-)r r! r# r r �__init__� threading�Event�_Timer__is_shutdown�_Timer__is_stopped�Lock�mutex� Condition� not_empty�daemon�nextr �name)r r! r" r r# r$ r r r r r% . s
�
zTimer.__init__)r c C sn | j �L t| j�\}}|d u rD|d u r2| j �d� |W d � S W d � n1 sX0 Y | j�|�S )Ng �?)r- r/ � scheduler�waitr! Z apply_entry)r �delay�entryr r r � _next_entryC s 0zTimer._next_entryc
C s� zrd| _ t| j�| _| j�� sN| �� }|r| jr:| �|� td u rDqNt|� qz| j �
� W n t yn Y n0 W nH t y� } z0t
jd|dd� tj�� t�d� W Y d }~n
d }~0 0 d S )NTzThread Timer crashed: %r)�exc_infor )r �iterr! r1 r( �is_setr5 r r r) �set� TypeError� Exceptionr �error�sys�stderr�flush�os�_exit)r r3 �excr r r �runO s&
z Timer.runc C s. | j �� | jr*| j�� | �t� d| _d S )NF)r( r9 r r) r2 �join�THREAD_TIMEOUT_MAX�r r r r �stopg s
z
Timer.stopc C s* | j s&| �� s&| jr | �| � | �� d S �N)r �is_aliver# r rF r r r �ensure_startedn s
zTimer.ensure_started)�methr r r c O sV | � � | j�4 t| j|�|i |��}| j�� |W d � S 1 sH0 Y d S rH )rJ r+ �getattrr! r- �notify)r rK r r r4 r r r � _do_entert s
zTimer._do_enter)r4 �eta�priorityr c C s | j d|||d�S )NZenter_at)rP �rN )r r4 rO rP r r r �enter{ s z Timer.enterc O s | j dg|�R i |��S )N�call_atrQ �r r r r r r rS ~ s z
Timer.call_atc O s | j dg|�R i |��S )N� enter_afterrQ rT r r r rU � s zTimer.enter_afterc O s | j dg|�R i |��S )N�
call_afterrQ rT r r r rV � s zTimer.call_afterc O s | j dg|�R i |��S )N�call_repeatedlyrQ rT r r r rW � s zTimer.call_repeatedly�
)�secsrP r c C s | � |tj|� d S rH )rV r= �exit)r rY rP r r r �
exit_after� s zTimer.exit_after)�trefr c C s |� � d S rH )�cancel)r r\ r r r r] � s z Timer.cancelc C s | j �� d S rH )r! �clearrF r r r r^ � s z Timer.clearc C s
t | � S rH )�lenrF r r r �empty� s z Timer.emptyc C s
t | j�S rH )r_ r! rF r r r �__len__� s z
Timer.__len__c C s dS )z``bool(timer)``.Tr rF r r r �__bool__� s zTimer.__bool__c C s | j jS rH )r! �queuerF r r r rc � s z Timer.queue)NNNNN)N)rX )-�__name__�
__module__� __qualname__�__doc__r
r r �bool�__annotations__r r r �floatr r r r r r; r% r5 �__next__r/ rC rG rJ �strrN �intrR rS rU rV rW r[ r] r^ r` ra rb � __nonzero__�property�listrc �
__classcell__r r r r r sN
�
�
r )rg r@ r= r& � itertoolsr r rE �timer �typingr r r r r Zkombu.asynchronous.timerr
r r r r
�environ�getr �__all__�Threadr r r r �<module> s