U
vi @ 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
ZedZG dd dee jZ dS ) N)deque)DequeOptionalTypeVar)abctyping)
Disposable)default_thread_factory)
DELTA_ZERO)DisposedException)
PriorityQueue )PeriodicScheduler)
ScheduledItemZRx_TStatec s e Zd ZdZdeej edd fdd
Zd ej e
ee
e j ddd Z
d ejej e
ee
e j d
d d Zd ejej e
ee
e j d
d
dZd ejeje
ee
e j d fdd
ZedddZddddZddddZddddZ ZS ) EventLoopSchedulerzFCreates an object that schedules units of work on a designated thread.NF)thread_factory
exit_if_emptyreturnc sJ t d| _|pt| _d | _tt | _ t
| _ t | _
|| _d S )NF)super__init__ _is_disposedr _thread_factory_thread threading ConditionLock
_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__)actionstater c C s | j | j||dS )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_absolutenow)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 enqueuenotify_ensure_threadr cancel)r! r, r& r' dtsir$ r$ r% r) O s
z$EventLoopScheduler.schedule_absolute)periodr& r' r c s | j r t t j|||dS )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 runstart)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 | jrW 5 Q R qnp| jr$| j}| j }|j|
}|dkrJtd| | j| n&| jr@d| _W 5 Q R dS | j W 5 Q R X qdS )zEvent 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 popleftdequeueZ is_cancelledZinvoke
total_secondslogdebugwaitr r )r! readytimeZdueitemsecondsr$ 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 ZStartableFactoryboolr 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% s