/usr/local/lib/python3.9/site-packages/asgiref/__pycache__
a Ұ�h= � @ s� d dl Z d dlZd dlmZ d dlmZmZ d dlmZm Z m Z e j dkrXd dlm Z n d dl m Z e d�Ze d�Ze d �ZG d d � d �ZG d d � d e�ZdS )� N)�deque)�Executor�Future)�Any�Callable�TypeVar)� � )� ParamSpec�_T�_P�_Rc @ s> e Zd ZdZdeeef ejejd�dd�Z dd�dd �Z dS ) � _WorkItemz� Represents an item needing to be run in the executor. Copied from ThreadPoolExecutor (but it's private, so we're not going to rely on importing it) � Future[_R]��future�fn�args�kwargsc O s || _ || _|| _|| _d S )Nr )�selfr r r r � r �I/usr/local/lib/python3.9/site-packages/asgiref/current_thread_executor.py�__init__ s z_WorkItem.__init__N)�returnc C sp d}| j �� sd S z| j| ji | j��}W n4 ty^ } z | j �|� d } W Y d }~nd }~0 0 | j �|� d S �NT)r Z set_running_or_notify_cancelr r r � BaseExceptionZ set_exceptionZ set_result)r Z__traceback_hide__�result�excr r r �run# s z _WorkItem.run) �__name__� __module__� __qualname__�__doc__r r r r r r r r r r r r s � r c @ sP e Zd ZdZddd�dd�Zddd�d d �Zeeef ej ej d d �d d�Z dS )�CurrentThreadExecutorz� An Executor that actually runs code in the thread it is instantiated in. Passed to other threads running async code, so they can run sync code in the thread they came from. z CurrentThreadExecutor | NoneN)� old_executorr c C s6 t �� | _t �t �� �| _tt � | _d| _ || _ d S )NF) � threading�current_thread� _work_thread� Condition�Lock� _work_readyr r � _work_items�_broken� _old_executor)r r$ r r r r 8 s z CurrentThreadExecutor.__init__� Future[Any]�r r c s� t �� � jkrtd��ddd�� fdd� }|�|� � j�F � jsT� jsT� j�� q<� jshW d � q�� j� � }W d � n1 s�0 Y |� � ~q4dS )z� Runs the code in the work queue until a result is available from the future. Should be run from the thread the executor is initialised in. z<You cannot run CurrentThreadExecutor from a different threadr. Nr/ c s: � j � d� _� j �� W d � n1 s,0 Y d S r )r* r, �notify)r �r r r �doneJ s z4CurrentThreadExecutor.run_until_future.<locals>.done) r% r& r' � RuntimeErrorZadd_done_callbackr* r+ r, �wait�popleftr )r r r2 � work_itemr r1 r �run_until_future? s � (z&CurrentThreadExecutor.run_until_futurer )r r r r c O s� t �� | jkrtd��t� }t||g|�R i |��}| }|j�: |jsj|j� |� |j� � W d � q�W d � n1 s~0 Y |j d u r�td��|j }q8|S )Nz@You cannot submit onto CurrentThreadExecutor from its own threadz/CurrentThreadExecutor already quit or is broken) r% r& r' r3 r r r* r, r+ �appendr0 r- )r r r r �fr6 �executorr r r �submit] s � , z CurrentThreadExecutor.submit) r r r! r" r r7 r r r r r r; r r r r r# 1 s �r# )�sysr% � collectionsr �concurrent.futuresr r �typingr r r � version_infor Ztyping_extensionsr r r r r# r r r r �<module> s
.
Edit
..
Edit
__init__.cpython-39.pyc
Edit
compatibility.cpython-39.pyc
Edit
current_thread_executor.cpython-39.pyc
Edit
local.cpython-39.pyc
Edit
server.cpython-39.pyc
Edit
sync.cpython-39.pyc
Edit
testing.cpython-39.pyc
Edit
timeout.cpython-39.pyc
Edit
typing.cpython-39.pyc
Edit
wsgi.cpython-39.pyc
Edit