$%hUddlmZddlZddlZddlZddlZddlmZddlm Z ddl m Z ddl m Z mZmZddlmZmZdd lmZdd lmZdd lmZej2d k\r dd l mZmZndd lmZmZdZded<dZded<dZ ded<dZ!ded<dZ"edZ#edZ$eeddZ%eedZ&GddZ'd dZ(dd d!dZ)d"dZ*y)#) annotationsN)deque)Callable)dedent)AnyFinalTypeVar) current_time to_thread)BrokenWorkerIntepreter)CapacityLimiter)RunVar) ) TypeVarTupleUnpackrUNBOUND FMT_UNPICKLED FMT_PICKLEDDEFAULT_CPU_COUNTT_RetvalPosArgsTWorker_available_workers_default_interpreter_limiterceZdZUeedddZdZded<dZded <d ed <d ed <dd Z ddZ ddZ ddZ y)ra import _interpqueues as queues import _interpreters as interpreters from pickle import loads, dumps, HIGHEST_PROTOCOL item = queues.get(queue_id)[0] try: func, args = loads(item) retval = func(*args) except BaseException as exc: is_exception = True retval = exc else: is_exception = False try: queues.put(queue_id, (retval, is_exception), FMT_UNPICKLED, UNBOUND) except interpreters.NotShareableError: retval = dumps(retval, HIGHEST_PROTOCOL) queues.put(queue_id, (retval, is_exception), FMT_PICKLED, UNBOUND) zexecrfloat last_usedFbool _initializedint_interpreter_id _queue_idcddl}ddl}|j|_|jdtt |_d|_|j|j|j ttt dy)NrrT)queue_idrrr) _interpqueues _interpreterscreater'rrr(r%set___main___attrsrselfqueues interpreterss R/var/www/skyplay_api_hub/venv/lib/python3.12/site-packages/anyio/to_interpreter.py initializezWorker.initializeFsa&,+224q-A ''   NN*!."   cddl}ddl}|jr7|j|j|j|j yy)Nr)r+r,r%destroyr'r(r/s r3r7zWorker.destroyWs:&,     !5!5 6 NN4>> * r5cddl}ddl}|js|jt j ||ftj }|j|j|tt|j|j|jx}r t||j|jdd\\}}} | tk(rt j |}||fS)Nrr)r+r,r%r4pickledumpsHIGHEST_PROTOCOLputr(rrr!r' _run_funcr getloads) r0funcargsr1r2payloadexc_infores is_exceptionfmts r3_callz Worker._call_s ',  OO ,,d|V-D-DE 4>>7KA$(()=)=t~~N N8 N(2 2#)::dnn#=bq#A lS + ,,s#CL  r5cvKtj|j|||d{\}}|r||S7 w)Nlimiter)r run_syncrG)r0r@rArJresultrEs r3callz Worker.callxsF &/%7%7 JJ   &   L  s '979N)returnNone)r@Callable[..., T_Retval]rA tuple[Any]rNztuple[Any, bool])r@rPrArQrJrrNr) __name__ __module__ __qualname__compilerr=r#__annotations__r%r4r7rGrMr5r3rr%s  * /I4IuL$N "+!%!!  !2%!   r5cR|D]}|j|jy)N)r7clear)workersworkers r3 _stop_workersr\s& MMOr5rIc,Ktjdkr td| t} tj }|4d{ |j}dddd{ j|||d{t!}|rT||dj"z t$krn:t'j(|j+j,|d{|rTt!|_|j/|S#t $r=t}tj|tjt|Y wxYw7 #t$rt}YwxYw7#1d{7swYxYw77#t!}|rU||dj"z t$krn;t'j(|j+j,|d{7|rUt!_|j/|wxYww)aF Call the given function with the given arguments in a subinterpreter. If the ``cancellable`` option is enabled and the task waiting for its completion is cancelled, the call will still run its course but its return value (or any raised exception) will be ignored. .. warning:: This feature is **experimental**. The upstream interpreter API has not yet been finalized or thoroughly tested, so don't rely on this for anything mission critical. :param func: a callable :param args: positional arguments for the callable :param limiter: capacity limiter to use to limit the total amount of subinterpreters running (if omitted, the default limiter is used) :return: the result of the call :raises BrokenWorkerIntepreter: if there's an internal error in a subinterpreter )r z,subinterpreters require at least Python 3.13NrrI)sys version_info RuntimeError#current_default_interpreter_limiter _idle_workersr> LookupErrorrsetatexitregisterr\pop IndexErrorrrMr r#MAX_WORKER_IDLE_TIMEr rKpopleftr7append)r@rJrA idle_workersr[nows r3rKrKs0 7"IJJ575$((*  !%%'F $[[tW55n\!_...2FF$$\%9%9%;%C%CWU U U  (>F#/ 5w ,' |45  XF 6 V n\!_...2FF$$\%9%9%;%C%CWU U U  (>F#s+HD HE H E3E H)E0*H/FF F AH!F "H)!H AE HEHE-)E3,E--E30H3F9E< :FH F HAH'G*(H0!HHc tjS#t$r?tt j xst }tj||cYSwxYw)z Return the capacity limiter that is used by default to limit the number of concurrently running subinterpreters. Defaults to the number of CPU cores. :return: a capacity limiter object )rr>rdros cpu_countrrerIs r3rbrbsN+//11 !",,."E4EF$((1sAAA)rZz deque[Worker]rNrO)r@z&Callable[[Unpack[PosArgsT]], T_Retval]rAzUnpack[PosArgsT]rJzCapacityLimiter | NonerNr)rNr)+ __future__rrfrpr9r_ collectionsrcollections.abcrtextwraprtypingrrr r r _core._exceptionsr _core._synchronizationrlowlevelrr`rrtyping_extensionsrrVrrrrjrrrcrrr\rKrbrWr5r3r|s" $&&%53w++6 u U5 :   #'uX'(<= 6vo67UVbbJ'+7$ 07$ 7$$7$ 7$tr5