i - dZddlZgdejdddkrgdngzZdgZddlZdZegd z Zed e ed red ej Z dd l m Z dd l mZddlmZddlmZddlmZddlmZddlmZddlmZddlmZddlmZe edrede edredd(dZd)dZd)dZ d*dZ!GddZ"d Z#Gd!d"eZ$e$xZ%Z&d#Z'e ed$r ej(Z)d(d%Z(ne*d$eee+ed&ZeezZ,e,*d'dS)+aK Implementation of the standard :mod:`thread` module that spawns greenlets. .. note:: This module is a helper for :mod:`gevent.monkey` and is not intended to be used directly. For spawning greenlets in your applications, prefer higher level constructs like :class:`gevent.Greenlet` class or :func:`gevent.spawn`. N) allocate_lock get_identexitLockType stack_sizestart_new_thread_local) )start_joinable_threadlock _ThreadHandle_make_thread_handleerror_thread) TIMEOUT_MAXallocate exit_threadinterrupt_main start_new get_native_iddaemon_threads_allowed)PYPY) copy_globals) getcurrent GreenletExit)sleep)get_hub_if_exists)Greenlet)BoundedSemaphore)local)LoopExitRLockset_namec@|t}t|SN)rid)grs 8/usr/local/lib/python3.11/dist-packages/gevent/thread.pyrrOs z \\ b66McZ|tj|g|Ri|}ntj|g|R}|Sr()r!spawn)functionargskwargsgreenlets r+_start_new_greenletr4UsE >((2T222 Or,c>tt|||Sr()rr4)r0r1r2s r+rr\s (4@@ A AAr,Tct|}|t}n:t|tstd|jrt d|||S)a *For internal use only*: start a new thread. Like start_new_thread(), this starts a new thread calling the given function. Unlike start_new_thread(), this returns a handle object with methods to join or detach the given thread. This function is not for third-party code, please use the `threading` module instead. During finalization the runtime will not wait for the thread to exit if daemon is True. If handle is provided it must be a newly created thread._ThreadHandle instance. NzMust be a gevent thread handlezthread already started)r4r isinstanceAssertionError _had_greenlet RuntimeError _set_greenlet)r0handledaemonr3s r+r r _sw2#8,,H~  . .5=>>>  53444 """ Mr,cZeZdZdZdZdZdZdZd dZe dZ d Z dd Z d Z dS)rcdS)zDoes nothing; ignores argsNr-)self_args_kwargss r+__init__z_ThreadHandle.__init__sr,NFcHddlm}|J|||_d|_dS)Nr)refT)weakrefrE _greenlet_refr9)r@gletrEs r+r;z_ThreadHandle._set_greenlets> SYY!r,c<|j|ndSr()rGr@s r+ _get_greenletz_ThreadHandle._get_greenlets)!-     r,c|dkrdn|}|jstd|}||turtdt |dr||Sddlm}d}|r ||z}|s5|||krdStd|5dS)NrLthread not startedzCannot join current threadjoinr)timeMbP?) r9r:rKrhasattrrOrPis_doner)r@timeoutrHrPends r+rOz_ThreadHandle.joins"R--$$W! 5344 4!!##  z||##"#?@@@tV$$ *yy))) " ! ! ! ! !C 'dffw&llnn ?ttvv||Fe llnn tr,cP|}|t|SdSr()rKrr@rHs r+identz_ThreadHandle.idents*!!##  T?? "tr,c@|}|dS|jSNT)rKdeadrWs r+rSz_ThreadHandle.is_dones%!!## <4yr,Tcf|jstdd|_|rtddSdS)a[ Mark the thread as complete. This releases our reference (if any) to our greenlet. By default, this will bounce back to the hub so that waiters in ``join`` can get notified. Set *enter_hub* to false not to do this. This private API is tightly coupled to our ``threading`` implementation. rNNrQ)r9r:rGr)r@ enter_hubs r+ _set_donez_ThreadHandle._set_donesI! 5344 4!   %LLLLL  r,czd|jj|jjt||fzS)Nz<%s.%s at 0x%x greenlet=%r>) __class__ __module____name__r)rKrJs r+__repr__z_ThreadHandle.__repr__s<, N % N # tHH    0   r,)rL)T)rbra __qualname__rCrGr9r;rKrOpropertyrXrSr^rcr-r,r+rrs)))MM"""    @X *     r,rcdt}|t|S)z Called on 3.13 after forking in the child. Takes ``(module, ident)``, returns a handle object with that ident. )rr;r)rAr<s r+rrs*__F &&& Mr,cdeZdZdZejZereZej Z fdZ e dZ ddZxZS)rz The basic lock type. .. versionchanged:: 24.10.1 Subclassing this object is no longer allowed. This matches the Python 3 API. cHtdS)z .. versionchanged:: 24.10.1 No longer accepts arguments to pass to the super class. If you want a semaphore with a different count, use a semaphore class directly. This matches the Lock API of Python 3 N)superrC)r@r`s r+rCzLockType.__init__ s! r,ctr() TypeError)clss r+__init_subclass__zLockType.__init_subclass__sr,TrLcT|dkrd}|s|td|/|dkrtd||jkrtd tj|||}n#t $r|rd}YnwxYw|s,|s*t turt|S)NrLz/can't specify a timeout for a non-blocking callrz'timeout value must be strictly positiveztimeout value is too largeF) ValueError _TIMEOUT_MAX OverflowErrorr"acquirer$rr r)r@blockingrTacquireds r+rrzLockType.acquires b==G PG/NOO O  {{ !JKKK***#$@AAA '/hHHHH     HHH   Z\\ARATAT-T-T GGGsA%%A76A7)TrL)rbrard__doc__ __thread__r_OVER_RELEASE_ERRORrr:rrprC classmethodrmrr __classcell__)r`s@r+rrs%* +*)L[++++++++r,rctr(rr-r,r+rrKs r,rch|tS|tkrt|SdSr()_original_stack_size)sizes r+rrRs; <')) ) &(( ( ('-- - ) (r,) only_namesignore_missing_namesr r()r-NrZ)-rusys version_info__implements__ __imports__rrv __target__appendrRrgevent._compatr gevent._utilr gevent.hubrrrgevent._hub_localr gevent.greenletr! gevent.lockr" gevent.localr#r gevent.exceptionsr$rr4rr rrrrrrrr|removeglobals__all__r-r,r+rsc    bqbW$$  +$i     ?### 7:/001/000%%%%%%!!!!!!######//////$$$$$$((((((((((((&&&&&& 7:w w 7:z""#z""" BBBB%%%%Nf f f f f f f f P   JJJJJJJJ^   7:|$$ (%0.....,'''l:wwyy&104666  ; &xr,