h%SSKJr SSKrSSKrSSKrSSKrSSKJr SSKJ r SSK J r SSK J r JrJr SSKJrJr SS KJr SS KJr SS KJr \R2S :a SS K JrJr OSS KJrJr SrS\S'SrS\S'Sr S\S'Sr!S\S'Sr"\"S5r#\"S5r$\\S"S5r%\\"S5r&"SS5r'S Sjr(SS.S!Sjjr)S"Sjr*g)#) annotationsN)deque)Callable)dedent)AnyFinalTypeVar) current_time to_thread)BrokenWorkerIntepreter)CapacityLimiter)RunVar) ) TypeVarTupleUnpackrUNBOUND FMT_UNPICKLED FMT_PICKLEDDEFAULT_CPU_COUNTT_RetvalPosArgsTWorker_available_workers_default_interpreter_limiterc\rSrSr%\"\"S5SS5rSrS\S'Sr S \S 'S \S 'S \S 'SSjr SSjr SSjr SSjr Srg)r%a 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_idcSSKnSSKnUR5UlURS[[ 5UlSUlURURUR [[[ S.5 g)NrrT)queue_idrrr) _interpqueues _interpreterscreater(rrr)r&set___main___attrsrselfqueues interpreterss F/var/www/html/env/lib/python3.13/site-packages/anyio/to_interpreter.py initializeWorker.initializeFsa&,+224q-A ''   NN*!."   cSSKnSSKnUR(a7URUR5 URUR 5 gg)Nr)r,r-r&destroyr(r)r0s r4r9Worker.destroyWs:&,     !5!5 6 NN4>> * r7cSSKnSSKnUR(dUR5 [R "X4[R 5nURURU[[5 URURUR5=n(a [U5eURUR5SSuupxn U [:Xa[R "U5nXx4$)Nrr)r,r-r&r5pickledumpsHIGHEST_PROTOCOLputr)rrr"r( _run_funcr getloads) r1funcargsr2r3payloadexc_infores is_exceptionfmts r4_call Worker._call_s ',  OO ,,|V-D-DE 4>>7KA$(()=)=t~~N N8 N(2 2#)::dnn#=bq#A S + ,,s#C  r7cz# [R"URUUUS9IShvN upEU(aUeU$N7f)Nlimiter)r run_syncrJ)r1rCrDrNresultrHs r4call Worker.callxsC &/%7%7 JJ   &   L  s %;9;)r&r(r)N)returnNone)rCCallable[..., T_Retval]rD tuple[Any]rSztuple[Any, bool])rCrUrDrVrNrrSr)__name__ __module__ __qualname____firstlineno__compilerr@r$__annotations__r&r5r9rJrQ__static_attributes__r7r4rr%s  * /I4IuL$N "+!%!!  !2%!   r7cVUHnUR5 M UR5 g)N)r9clear)workersworkers r4 _stop_workersrcs! MMOr7rMcb# [RS::a [S5eUc [5n[R 5nUIShvN UR5nSSS5IShvN WRXU5IShvN [!5nU(aXXSSR"- [$::aO>[&R("UR+5R,US9IShvN U(aMX[!5UlUR/U5 $![ a> [5n[RU5 [R"[U5 GNf=fGN![a [5nGNf=fGN!,IShvN (df  GN(=fGNN![!5nU(aYXSSR"- [$::aO?[&R("UR+5R,US9IShvN U(aMY[!5WlUR/U5 f=f7f)a 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.13NrrM)sys version_info RuntimeError#current_default_interpreter_limiter _idle_workersrA LookupErrorrsetatexitregisterrcpop IndexErrorrrQr r$MAX_WORKER_IDLE_TIMEr rOpopleftr9append)rCrNrD idle_workersrbnows r4rOrOs0 7"IJJ575$((* w !%%'Fw $[[W55n!_...2FF$$\%9%9%;%C%CWU U U l (>F#/ 5w ,' |45  XF www6 V n!_...2FF$$\%9%9%;%C%CWU U U l (>F#s-H/DH/ E H/FE" H/+E=,H/1F FF AH/%F& H/3!H/AEH/EH/"E:6F9E::F=H/FF  FH/F H/ AH,<G?= H, !H,,H/c[R5$![aE [[R "5=(d [ 5n[RU5 Us$f=f)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 )rrArkros cpu_countrrlrMs r4ririsN+//11 !",,."E4EF$((1sA A%$A%)raz deque[Worker]rSrT)rCz&Callable[[Unpack[PosArgsT]], T_Retval]rDzUnpack[PosArgsT]rNzCapacityLimiter | NonerSr)rSr)+ __future__rrmrwr<rf collectionsrcollections.abcrtextwraprtypingrrr r r _core._exceptionsr _core._synchronizationrlowlevelrrgrrtyping_extensionsrr\rrrrqrrrjrrrcrOrir^r7r4rs" $&&%53w++6 u U5 :   #uX'(<= %o67UVbbJ'+7$ 07$ 7$$7$ 7$tr7