Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/celery/utils/__pycache__/timer2.cpython-39.pyc
Ðазад
a t�h� � @ s� d Z ddlZddlZddlZddlmZ ddlmZ ddlm Z ddl m Z ddl m Z ddl mZmZ ej�d �Zd ZG d d � d ej�Z dS ) 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)�Entry)�Timer)�logger� to_timestamp� TIMER_DEBUG)r �Scheduler r c s� e Zd ZdZeZeZdZdZed�Z e r4� fdd�Z d,� fdd� Z d d � Z e ZZd d � Zd d� Zdd� Zdd� Zd-dd�Zdd� Zdd� Zdd� Zdd � Zd.d d �Zd d!� Zd"d#� Zd$d%� Z d&d'� Z d(d)� Z e Z e d*d+� �Z!� Z"S )/r z^Timer thread. Note: This is only used for transports not supporting AsyncIO. FN� c s. dd l }td� |�� t� j|i |�� d S )Nr z- Timer starting)� traceback�print� print_stack�super�start)�self�args�kwargsr �� __class__� ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/celery/utils/timer2.pyr ' s z Timer.startc sx |p| j ||d�| _|| _|p"| j| _t� �� t�� | _t�� | _ t� � | _ t� | j �| _ d| _dt| j�� �| _d S )N)�on_error� max_intervalTzTimer-)r �schedule�on_start�on_tickr �__init__� threading�Event�_Timer__is_shutdown�_Timer__is_stopped�Lock�mutex� Condition� not_empty�daemon�next� _timer_count�name)r r r r r r r r r r r - s � zTimer.__init__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_entry? 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 )�running�iterr r* r �is_setr. r r r! �set� TypeError� Exceptionr �error�sys�stderr�flush�os�_exit)r r, �excr r r �runI s& z Timer.runc C s. | j �� | jr*| j�� | �t� d| _d S )NF)r r3 r0 r! r+ �join�THREAD_TIMEOUT_MAX�r r r r �stopa s z Timer.stopc C s* | j s&| �� s&| jr | �| � | �� d S �N)r0 �is_aliver r r@ r r r �ensure_startedh s zTimer.ensure_startedc O sV | � � | j�4 t| j|�|i |��}| j�� |W d � S 1 sH0 Y d S rB )rD r# �getattrr r% �notify)r �methr r r- r r r � _do_entern s zTimer._do_enterc C s | j d|||d�S )NZenter_at)�priority�rH )r r- �etarI r r r �enteru s z Timer.enterc O s | j dg|�R i |��S )N�call_atrJ �r r r r r r rM x s z Timer.call_atc O s | j dg|�R i |��S )N� enter_afterrJ rN r r r rO { s zTimer.enter_afterc O s | j dg|�R i |��S )N� call_afterrJ rN r r r rP ~ s zTimer.call_afterc O s | j dg|�R i |��S )N�call_repeatedlyrJ rN r r r rQ � s zTimer.call_repeatedly� c C s | � |tj|� d S rB )rP r7 �exit)r ZsecsrI r r r � exit_after� s zTimer.exit_afterc C s |� � d S rB )�cancel)r Ztrefr r r rU � s z Timer.cancelc C s | j �� d S rB )r �clearr@ r r r rV � s z Timer.clearc C s t | � S rB )�lenr@ r r r �empty� s z Timer.emptyc C s t | j�S rB )rW r r@ r r r �__len__� s z Timer.__len__c C s dS )z``bool(timer)``.Tr r@ r r r �__bool__� s zTimer.__bool__c C s | j jS rB )r �queuer@ r r r r[ � s z Timer.queue)NNNNN)N)rR )#�__name__� __module__� __qualname__�__doc__r r r0 r r r( r r r r. �__next__r' r= rA rD rH rL rM rO rP rQ rT rU rV rX rY rZ � __nonzero__�propertyr[ � __classcell__r r r r r s> � r )r_ r: r7 r � itertoolsr r r? �timer Zkombu.asynchronous.timerr r r r r �environ�getr �__all__�Threadr r r r �<module> s
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка