🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-09 07:23:00 | 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: trampoline.cpython-38.pyc
Read Only
U v�i7 � @ sX d dl mZ d dlmZmZ d dlmZ d dlmZ ddl m Z G dd� d�Z dgZ d S ) � )�deque)� Condition�Lock)�Deque)� PriorityQueue� )� ScheduledItemc @ sF e Zd Zdd�dd�Zed�dd�Zedd�dd �Zdd�d d �ZdS ) � TrampolineN)�returnc C s& d| _ t� | _t� | _t| j�| _d S )NT)�_idler �_queuer �_lockr � _condition��self� 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 �notify�clear�_run)r r r r r �run s zTrampoline.runc C s� t � }| j�F t| j�dkrN| j�� }|j|jjkrN| j�� |� |� qqNqW 5 Q R X t|�dkr~|� � }|� � sX|� � qX| j�P t| j�dkr�W 5 Q R � q�| j�� }|j|jj � � }|dkr�| j�|� W 5 Q R X qd S )Nr g )r r �lenr �peekZduetimeZ scheduler�now�dequeue�append�popleftZ 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 �<module> s 4
💾 Save Changes
❌ Cancel