🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-09 04:46:36 | 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: currentthreadscheduler.cpython-38.pyc
Read Only
U v�ia � @ s� d dl Z d dlmZmZmZ d dlmZ d dlmZ ddl m Z ddl m Z e � d�ZG d d � d e �ZG d d � d e�ZG d d� de�ZdS )� N)�Thread�current_thread�local)�MutableMapping)�WeakKeyDictionary� )� Trampoline)�TrampolineSchedulerZRxc @ s^ e Zd ZU dZe� Zeeeed f f e d< e d d�dd��Z dd�dd�Z e d�d d �ZdS ) �CurrentThreadSchedulera� Represents an object that schedules units of work on the current thread. You should never schedule timeouts using the *CurrentThreadScheduler*, as that will block the thread while waiting. Each instance manages a number of trampolines (and queues), one for each thread that calls a *schedule* method. These trampolines are automatically garbage-collected when threads disappear, because they're stored in a weak key dictionary. �_global��returnc C sd t � }tj�| �}|dkr,t� }|tj| < n|}z || }W n" tk r^ t� }|||< Y nX |S )aE Obtain a singleton instance for the current thread. Please note, if you pass this instance to another thread, it will effectively behave as if it were created by that other thread (separate trampoline and queue). Returns: The singleton *CurrentThreadScheduler* instance. N)r r r �getr �KeyError� CurrentThreadSchedulerSingleton)�cls�threadZ class_mapZ class_map_�self� r �[/opt/alt/python38/lib/python3.8/site-packages/reactivex/scheduler/currentthreadscheduler.py� singleton s � z CurrentThreadScheduler.singletonNc C s t � | _d S �N)r �_tramps�r r r r �__init__6 s z CurrentThreadScheduler.__init__c C s. t � }| j�|�}|d kr*t� }|| j|< |S r )r r r r )r r �trampr r r �get_trampoline9 s z%CurrentThreadScheduler.get_trampoline)�__name__� __module__� __qualname__�__doc__r r r �typer �__annotations__� classmethodr r r r r r r r r s �r c s" e Zd Zdd�� fdd� Z� ZS )�_LocalNr c s t � �� t� | _d S r )�superr r r r �� __class__r r r C s z_Local.__init__)r r r r � __classcell__r r r& r r$ B s r$ c @ s. e Zd Ze� Zdd�dd�Zed�dd�ZdS )r Nr c C s d S r r r r r r r M s z(CurrentThreadSchedulerSingleton.__init__c C s t jjS r )r �_localr r r r r r P s z.CurrentThreadSchedulerSingleton.get_trampoline)r r r r$ r) r r r r r r r r H s r )�logging� threadingr r r �typingr �weakrefr Z trampoliner Ztrampolineschedulerr � getLogger�logr r$ r r r r r �<module> s 6
💾 Save Changes
❌ Cancel