U Ú²g‰ã@s¢ddlZddlZddlZddlmZmZddlmZmZm Z m Z m Z ej dkr\ddlm Z n ddlm Z e dƒZe dƒZe dƒZGd d „d ƒZGd d „d eƒZdS) éN)ÚExecutorÚFuture)Ú TYPE_CHECKINGÚAnyÚCallableÚTypeVarÚUnion)éé )Ú ParamSpecÚ_TÚ_PÚ_Rc@s>eZdZdZdeeefejejdœ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ÚkwargscOs||_||_||_||_dS©Nr)Úselfrrrr©rúC/tmp/pip-unpacked-wheel-hay1n6u8/asgiref/current_thread_executor.pyÚ__init__sz_WorkItem.__init__N©Úreturnc Csjd}|j ¡sdSz|j|j|jŽ}Wn2tk rX}z|j |¡d}W5d}~XYnX|j |¡dS)NT)rZset_running_or_notify_cancelrrrÚ BaseExceptionZ set_exceptionZ set_result)rZ__traceback_hide__ÚresultÚexcrrrÚrun#s  z _WorkItem.run) Ú__name__Ú __module__Ú __qualname__Ú__doc__rr rrrrr rrrrrs û rc@sZeZdZdZddœdd„Zdddœdd „Zeeefej ej d d œd d „Z e sVdd„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. NrcCst ¡|_t ¡|_d|_dS)NF)Ú threadingÚcurrent_threadÚ _work_threadÚqueueÚQueueÚ _work_queueÚ_broken)rrrrr8s  zCurrentThreadExecutor.__init__z Future[Any])rrcCsjt ¡|jkrtdƒ‚| |jj¡z8|j ¡}||kr@W¢"dSt |t ƒsNt ‚|  ¡~q&W5d|_XdS)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. zs