🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-09 03:50:34 | 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: newthreadscheduler.cpython-38.pyc
Read Only
U v�ig � @ s� d dl Z d dlZd dlmZ d dlmZmZ d dlmZmZ d dlm Z d dl m Z ddl m Z dd lmZ ed �Ze �d �ZG d d � d e�ZdS )� N)�datetime)�Optional�TypeVar)�abc�typing)� Disposable)�default_thread_factory� )�EventLoopScheduler)�PeriodicScheduler�_TStateZRxc s� e Zd ZdZdeej dd�� fdd� Zdeje ee e j d�dd�Z dej eje ee e j d �d d �Zdejeje ee e j d �d d �Zdej eje ee e j d�dd�Z� ZS )�NewThreadSchedulerzHCreates an object that schedules each unit of work on a separate thread.N)�thread_factory�returnc s t � �� |pt| _d S �N)�super�__init__r r )�selfr �� __class__� �W/opt/alt/python38/lib/python3.8/site-packages/reactivex/scheduler/newthreadscheduler.pyr s �zNewThreadScheduler.__init__)�action�stater c C s t | jdd�}|�||�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). T�r Z exit_if_empty)r r �schedule)r r r � schedulerr r r r s �zNewThreadScheduler.schedule)�duetimer r r c C s t | jdd�}|�|||�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). Tr )r r �schedule_relative)r r r r r r r r r 0 s �z$NewThreadScheduler.schedule_relativec C s | � |�}| j|| j ||d�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 )� to_datetimer �now)r r r r �dtr r r �schedule_absoluteG s z$NewThreadScheduler.schedule_absolute)�periodr r r c s^ �� |����t�� �dd�� �����fdd� }��|�}|�� dd��fdd� }t|�S )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). N)r c sD �dkr�� �� ��� r d S �j} � �����j| �� �q d S )Ng )�wait�is_setr � total_seconds)�time�r �disposed�secondsr r �timeoutr r �runt s z1NewThreadScheduler.schedule_periodic.<locals>.runc s � � � d S r )�setr )r) r r �dispose� s z5NewThreadScheduler.schedule_periodic.<locals>.dispose)Z to_seconds� threading�Eventr �startr )r r# r r r, �threadr. r r( r �schedule_periodic\ s z$NewThreadScheduler.schedule_periodic)N)N)N)N)N)�__name__� __module__� __qualname__�__doc__r r ZStartableFactoryr ZScheduledActionr r ZDisposableBaser Z RelativeTimer Z AbsoluteTimer" ZScheduledPeriodicActionr3 � __classcell__r r r r r sB �� � � �� �� ��r )�loggingr/ r r r r Z reactivexr Zreactivex.disposabler Z reactivex.internal.concurrencyr Zeventloopschedulerr Zperiodicschedulerr r � getLogger�logr r r r r �<module> s
💾 Save Changes
❌ Cancel