🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-09 03:52:02 | 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: trampolinescheduler.cpython-38.pyc
Read Only
U v�i� � @ 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� de�ZdS )� N)�Optional�TypeVar)�abc�typing)�DisposableBase)�ScheduledAction)� DELTA_ZERO� )� ScheduledItem)� Scheduler)� Trampoline�_TStateZRxc @ s� e Zd ZdZdd�dd�Zed�dd�Zdeje e e ej d�d d �Z de jeje e e ej d �d d �Zde jeje e e ej d �dd�Zed�dd�Zee e e d�dd�ZdS )�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 �_tramp��self� 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)�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 z TrampolineScheduler.schedule)�duetimer r r c C s& t t| �|��}| j| j| ||d�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). r )�maxr Z to_timedeltar r )r r r r r r r �schedule_relative3 s z%TrampolineScheduler.schedule_relativec C s@ | � |�}|| jkr t�d� 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 �log�warningr r �runZ disposable)r r r r �dt�itemr 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 || d�S )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 �<module> s
💾 Save Changes
❌ Cancel