🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-09 04:47:59 | 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: threadpoolscheduler.cpython-38.pyc
Read Only
U v�i� � @ sP d dl mZmZ d dlmZmZ d dlmZmZ ddlm Z G dd� de �Z dS ) � )�Future�ThreadPoolExecutor)�Any�Optional)�abc�typing� )�NewThreadSchedulerc s@ e Zd ZdZG dd� dej�Zdee dd�� fdd� Z � Z S ) �ThreadPoolSchedulerz4A scheduler that schedules work via the thread pool.c @ s> e Zd ZdZeejd�dd�Zdd�dd�Zdd�d d �Z dS ) z$ThreadPoolScheduler.ThreadPoolThreadz&Wraps a concurrent future as a thread.)�executor�targetc C s || _ || _d | _d S �N)r r �future)�selfr r � r �X/opt/alt/python38/lib/python3.8/site-packages/reactivex/scheduler/threadpoolscheduler.py�__init__ s z-ThreadPoolScheduler.ThreadPoolThread.__init__N)�returnc C s | j �| j�| _d S r )r �submitr r �r r r r �start s z*ThreadPoolScheduler.ThreadPoolThread.startc C s | j r| j �� d S r )r �cancelr r r r r s z+ThreadPoolScheduler.ThreadPoolThread.cancel) �__name__� __module__� __qualname__�__doc__r r �StartableTargetr r r r r r r �ThreadPoolThread s � r N)� max_workersr c s4 t |d�� _tjtjd�� fdd� }t� �|� d S )N)r )r r c s � � � j| �S r )r r )r r r r �thread_factory s z4ThreadPoolScheduler.__init__.<locals>.thread_factory)r r r r r r �superr )r r r �� __class__r r r s �z ThreadPoolScheduler.__init__)N) r r r r r Z StartableBaser r �intr � __classcell__r r r! r r s r N) �concurrent.futuresr r r r r Z reactivexr Znewthreadschedulerr r r r r r �<module> s
💾 Save Changes
❌ Cancel