🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-09 03:46:01 | PHP 8.2.33
📂
/ (Root)
/
opt
/
alt
/
python38
/
lib
/
python3.8
/
site-packages
/
reactivex
/
scheduler
/
__pycache__
📍 /opt/alt/python38/lib/python3.8/site-packages/reactivex/scheduler/__pycache__
🔄 Refresh
✏️
Editing: eventloopscheduler.cpython-38.pyc
Read Only
U v�i� � @ s� d dl Z d dlZd dlmZ d dlmZmZmZ d dlm Z mZ d dl m Z d dl m Z d dlmZ d dlmZ d d lmZ d d lmZ d d lmZ e �d �Zed�ZG dd� dee j�Z dS )� N)�deque)�Deque�Optional�TypeVar)�abc�typing)� Disposable)�default_thread_factory)� DELTA_ZERO)�DisposedException)� PriorityQueue� )�PeriodicScheduler)� ScheduledItemZRx�_TStatec s� e Zd ZdZdeej edd�� fdd� Zd ej e ee e j d�dd �Z d ejej e ee e j d �d d �Zd ejej e ee e j d �d d�Zd ejeje ee e j d�� fdd� Zed�dd�Zdd�dd�Zdd�dd�Zdd�dd�Z� ZS ) �EventLoopSchedulerzFCreates an object that schedules units of work on a designated thread.NF)�thread_factory� exit_if_empty�returnc sJ t � �� d| _|pt| _d | _t�t�� �| _ t � | _ t � | _ || _d S )NF)�super�__init__� _is_disposedr �_thread_factory�_thread� threading� Condition�Lock� _conditionr �_queuer � _ready_list�_exit_if_empty)�selfr r �� __class__� �W/opt/alt/python38/lib/python3.8/site-packages/reactivex/scheduler/eventloopscheduler.pyr s �zEventLoopScheduler.__init__)�action�stater c C s | j | j||d�S )a! Schedules an action to be executed. Args: action: Action to be executed. state: [Optional] state to be given to the action function. Returns: The disposable object used to cancel the scheduled action (best effort). �r' )�schedule_absolute�now)r! r& r' r$ r$ r% �schedule* s zEventLoopScheduler.schedule)�duetimer& r' r c C s$ t t| �|��}| �| j| ||�S )au Schedules an action to be executed after duetime. Args: duetime: Relative time after which to execute the action. action: Action to be executed. state: [Optional] state to be given to the action function. Returns: The disposable object used to cancel the scheduled action (best effort). )�maxr Z to_timedeltar) r* )r! r, r& r' r$ r$ r% �schedule_relative: s z$EventLoopScheduler.schedule_relativec C sv | j r t� �| �|�}t| |||�}| j�< || jkrD| j�|� n | j� |� | j� � | � � W 5 Q R X t |j �S )ao Schedules an action to be executed at duetime. Args: duetime: Absolute time at which to execute the action. action: Action to be executed. state: [Optional] state to be given to the action function. Returns: The disposable object used to cancel the scheduled action (best effort). )r r � to_datetimer r r* r �appendr �enqueue�notify�_ensure_threadr �cancel)r! r, r& r' �dt�sir$ r$ r% r) O s z$EventLoopScheduler.schedule_absolute)�periodr& r' r c s | j r t� �t� j|||d�S )a� Schedules a periodic piece of work. Args: period: Period in seconds or timedelta for running the work periodically. action: Action to be executed. state: [Optional] Initial state passed to the action upon the first iteration. Returns: The disposable object used to cancel the scheduled recurring action (best effort). r( )r r r �schedule_periodic)r! r7 r& r' r" r$ r% r8 q s z$EventLoopScheduler.schedule_periodic)r c C s0 | j � | j o| jdk W 5 Q R � S Q R X dS )z0Checks if there is an event loop thread running.N)r r r �r! r$ r$ r% � _has_thread� s z EventLoopScheduler._has_threadc C s$ | j s | �| j�}|| _ |�� dS )zWEnsures there is an event loop thread running. Should be called under the gate.N)r r �run�start)r! �threadr$ r$ r% r3 � s z!EventLoopScheduler._ensure_threadc C sZ t � }| j�� | jr"W 5 Q R � dS | j}| jr~| j�� j}| jrb|| jd jkrb|�| j� � � q:||krlq~|�| j� � � q(| jr�|�| j� � � q~W 5 Q R X |r�|� � }|� � s�|� � q�| j�� | jr�W 5 Q R � qnp| j�r$| j}| j�� }|j| � � }|dk�rJt�d|� | j�|� n&| j�r@d| _W 5 Q R � dS | j�� W 5 Q R X qdS )z�Event loop scheduled on the designated event loop thread. The loop is suspended/resumed using the condition which gets notified by calls to Schedule or calls to dispose.Nr z timeout: %s)r r r r* r �peekr, r r0 �popleft�dequeueZ is_cancelledZinvoke� total_seconds�log�debug�waitr r )r! �ready�timeZdue�item�secondsr$ r$ r% r; � s@ zEventLoopScheduler.runc C s, | j � | js d| _| j �� W 5 Q R X dS )zxEnds the thread associated with this scheduler. All remaining work in the scheduler queue is abandoned. TN)r r r2 r9 r$ r$ r% �dispose� s zEventLoopScheduler.dispose)NF)N)N)N)N)�__name__� __module__� __qualname__�__doc__r r ZStartableFactory�boolr ZScheduledActionr r �DisposableBaser+ Z RelativeTimer. Z AbsoluteTimer) ZScheduledPeriodicActionr8 r: r3 r; rI � __classcell__r$ r$ r" r% r sN �� � � �� �� & �� :r ) �loggingr � collectionsr r r r r Z reactivexr Zreactivex.disposabler Z reactivex.internal.concurrencyr Z reactivex.internal.constantsr Z reactivex.internal.exceptionsr Z reactivex.internal.priorityqueuer Zperiodicschedulerr Z scheduleditemr � getLoggerrB r rO r r$ r$ r$ r% �<module> s
💾 Save Changes
❌ Cancel