U
vi7 @ sX d dl mZ d dlmZmZ d dlmZ d dlmZ ddl m
Z
G dd dZ dgZ d S )
)deque) ConditionLock)Deque)
PriorityQueue )
ScheduledItemc @ sF e Zd ZddddZedddZedddd Zddd
d ZdS )
TrampolineN)returnc C s& d| _ t | _t | _t| j| _d S )NT)_idler _queuer _lockr
_conditionself r O/opt/alt/python38/lib/python3.8/site-packages/reactivex/scheduler/trampoline.py__init__ s zTrampoline.__init__c
C s$ | j | jW 5 Q R S Q R X d S )N)r
r r r r r idle s zTrampoline.idle)itemr
c C sz | j 8 | j| | jr"d| _n| j W 5 Q R d S W 5 Q R X z | W 5 | j d| _| j W 5 Q R X X d S )NFT)r
r enqueuer r notifyclear_run)r r r r r run s
zTrampoline.runc C s t }| jF t| jdkrN| j }|j|jjkrN| j | | qqNqW 5 Q R X t|dkr~|
}| sX| qX| jP t| jdkrW 5 Q R q| j }|j|jj
}|dkr| j| W 5 Q R X qd S )Nr g )r r
lenr peekZduetimeZ schedulernowdequeueappendpopleftZ is_cancelledZinvoke
total_secondsr wait)r readyr secondsr r r r $ s&
zTrampoline._run) __name__
__module__ __qualname__r boolr r r r r r r r r
s r N)
collectionsr threadingr r typingr Z reactivex.internal.priorityqueuer Z
scheduleditemr r __all__r r r r s 4