Jn6hddlZddlZddlZddlmZmZddlmZmZm Z m Z m Z ejdk\rddlm Z nddlm Z e dZe dZe dZGd d ZGd d eZy) N)ExecutorFuture) TYPE_CHECKINGAnyCallableTypeVarUnion) ) ParamSpec_T_P_RcbeZdZdZdddeeefdejdejfdZ d d Z y) _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]fnargskwargsc<||_||_||_||_yN)rrrr)selfrrrrs p/var/www/django-portfolio.reubendavern.link/venv/lib/python3.12/site-packages/asgiref/current_thread_executor.py__init__z_WorkItem.__init__s    Nc(d}|jjsy |j|ji|j}|jj |y#t $r'}|jj|d}Yd}~yd}~wwxYw)NT)rset_running_or_notify_cancelrrr set_result BaseException set_exception)r__traceback_hide__resultexcs rrunz _WorkItem.run#sz!{{779  +TWWdii74;;7F KK " "6 *   KK % %c *D s&A!! B*B  BreturnN) __name__ __module__ __qualname____doc__rrrrrrr%rrrrsH   RV  ww  ))  +rrcveZdZdZd dZd dZdeeefdejdejdd fd Z e sd Z yy)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. r'Ncvtj|_tj|_d|_y)NF) threadingcurrent_thread _work_threadqueueQueue _work_queue_broken)rs rrzCurrentThreadExecutor.__init__8s(%446IN rcVtj|jk7r td|j |j j  |j j}||ur d|_yt|tsJ|j~K#d|_wxYw)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. zrrrrrrArrCr,rrr.r.1s\   2 RV ww))   4  5 rr.)r3sysr0concurrent.futuresrrtypingrrrrr version_infor typing_extensionsr rrrr.r,rrrIs_ /??w + T]t_ T]++@B5HB5r