U
vi @ s d dl Z d dlmZmZ d dlmZmZ d dlmZ d dlm Z d dl
m Z ddl m
Z
dd lmZ dd
lmZ ed Ze d ZG d
d deZdS ) N)OptionalTypeVar)abctyping)DisposableBase)ScheduledAction)
DELTA_ZERO )
ScheduledItem) Scheduler)
Trampoline_TStateZRxc @ s e Zd ZdZddddZedddZdeje e
e ej dd d
Z de
jeje e
e ej d d d
Zde
jeje e
e ej d ddZedddZee e
e dddZdS )TrampolineSchedulera Represents an object that schedules units of work on the trampoline.
You should never schedule timeouts using the *TrampolineScheduler*, as
it will block the thread while waiting.
Each instance has its own trampoline (and queue), and you can schedule work
on it from different threads. Beware though, that the first thread to call
a *schedule* method while the trampoline is idle will then remain occupied
until the queue is empty.
N)returnc C s t | _d S N)r _trampself r X/opt/alt/python38/lib/python3.8/site-packages/reactivex/scheduler/trampolinescheduler.py__init__ s z TrampolineScheduler.__init__c C s | j S r )r r r r r get_trampoline s z"TrampolineScheduler.get_trampoline)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 z TrampolineScheduler.schedule)duetimer r r c C s& t t| |}| j| j| ||dS )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).
r )maxr Z to_timedeltar r )r r r r r r r schedule_relative3 s z%TrampolineScheduler.schedule_relativec C s@ | |}|| jkr td t| |||}| | |jS )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).
z Do not schedule blocking work!) to_datetimer logwarningr
r runZ
disposable)r r r r dtitemr r r r H s
z%TrampolineScheduler.schedule_absolutec C s | S )a Test if scheduling is required.
Gets a value indicating whether the caller must call a
schedule method. If the trampoline is active, then it returns
False; otherwise, if the trampoline is not active, then it
returns True.
)r idler r r r schedule_requiredc s z%TrampolineScheduler.schedule_required)r r c C s | r| |S || dS )z+Method for testing the TrampolineScheduler.N)r( r )r r r r r ensure_trampolinem s
z%TrampolineScheduler.ensure_trampoline)N)N)N)__name__
__module__ __qualname____doc__r r r r r r
r r r r Z RelativeTimer Z AbsoluteTimer boolr( r) r r r r r s6
r )loggingr r r Z reactivexr Zreactivex.abc.disposabler Zreactivex.abc.schedulerr Z reactivex.internal.constantsr Z
scheduleditemr
Z schedulerr Z
trampoliner r
getLoggerr" r r r r r s