o h=@sddlZddlZddlmZddlmZmZddlmZm Z m Z ej dkr,ddlm Z nddl m Z e dZe dZe d ZGd d d ZGd d d eZdS)N)deque)ExecutorFuture)AnyCallableTypeVar) ) ParamSpec_T_P_Rc@s@eZdZdZdddeeefdejdejfddZ d d d Z d S) _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 Future[_R]fnargskwargscOs||_||_||_||_dS)N)rrrr)selfrrrrr_/var/www/html/premium_crap/venv/lib/python3.10/site-packages/asgiref/current_thread_executor.py__init__s z_WorkItem.__init__returnNc Csrd}|js dSz |j|ji|j}Wnty0}z|j|d}WYd}~dSd}~ww|j|dSNT)rset_running_or_notify_cancelrrr BaseException set_exception set_result)r__traceback_hide__resultexcrrrrun#s  z _WorkItem.run)rN) __name__ __module__ __qualname____doc__rr r rrrr!rrrrrs   rc@sJeZdZdZdddZdd d Zd eeefd ej dej ddfddZ 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. old_executorCurrentThreadExecutor | NonerNcCs6t|_tt|_tt|_d|_ ||_ dS)NF) threadingcurrent_thread _work_thread ConditionLock _work_readyrr _work_items_broken _old_executor)rr'rrrr8s   zCurrentThreadExecutor.__init__r Future[Any]cstjkr tdd fdd }|| j*js-js-jjs-jr"js9 WddSj }Wdn1sHwY| ~q) 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.doneTrr2rN) r)r*r+ RuntimeErroradd_done_callbackr.r/r0waitpopleftr!)rrr5 work_itemrr4rrun_until_future?s&     z&CurrentThreadExecutor.run_until_futurerrrrcOst|jkr tdt}t||g|Ri|}|} |j|js8|j ||j  Wd|SWdn1sBwY|j durPtd|j }q)Nz@You cannot submit onto CurrentThreadExecutor from its own threadTz/CurrentThreadExecutor already quit or is broken) r)r*r+r7rrr.r0r/appendr3r1)rrrrfr;executorrrrsubmit]s*     zCurrentThreadExecutor.submit)r'r(rNr6) r"r#r$r%rr<rr r rrr@rrrrr&1s   r&)sysr) collectionsrconcurrent.futuresrrtypingrrr version_infor typing_extensionsr r r rr&rrrrs