o ,wi,@sdZddlZgdejdddkrgdngZdgZddlZdZegd 7Zed e ed r7ed ej Z dd l m Z dd l mZddlmZddlmZddlmZddlmZddlmZddlmZddlmZddlmZe edrede edredd.ddZd/ddZd/ddZ d0d d!Z!Gd"d#d#Z"d$d%Z#Gd&d'd'eZ$e$Z%Z&d(d)Z'e ed*rej(Z)d.d+d*Z(ne*d*eee+edd,ZeeZ,e,*d-dS)1aK 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_namecCs|durt}t|SN)rid)grr)J/home/ubuntu/sommelier/.venv/lib/python3.10/site-packages/gevent/thread.pyrOsrr)cCs:|durtj|g|Ri|}|Stj|g|R}|Sr&)r spawn)functionargskwargsgreenletr)r)r*_start_new_greenletUs r0cCstt|||Sr&)rr0)r,r-r.r)r)r*r\srTcCsFt|}|dur t}nt|tstd|jrtd|||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)r0r isinstanceAssertionError _had_greenlet RuntimeError _set_greenlet)r,handledaemonr/r)r)r*r _s  r c@s\eZdZddZdZdZddZddZdd d Ze d d Z ddZ dddZ ddZ dS)rcOsdS)zDoes nothing; ignores argsNr))self_args_kwargsr)r)r*__init__sz_ThreadHandle.__init__NFcCs,ddlm}|dus J|||_d|_dS)Nr)refT)weakrefr< _greenlet_refr3)r8gletr<r)r)r*r5s    z_ThreadHandle._set_greenletcCs|jdur |SdSr&)r>r8r)r)r* _get_greenlets z_ThreadHandle._get_greenletcCs|dkrdn|}|jstd|}|durP|tur tdt|dr*||Sddlm}d}|r9||}|sP|durH||krHdStd|r=dS)NrBthread not startedzCannot join current threadjoinr)timeMbP?) r3r4rArhasattrrDrEis_doner)r8timeoutr?rEendr)r)r*rDs&     z_ThreadHandle.joincCs|}|dur t|SdSr&)rArr8r?r)r)r*identsz_ThreadHandle.identcCs|}|dur dS|jSNT)rAdeadrKr)r)r*rHsz_ThreadHandle.is_doneTcCs(|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. rCNrF)r3r4r>r)r8 enter_hubr)r)r* _set_dones   z_ThreadHandle._set_donecCs d|jj|jjt||fS)Nz<%s.%s at 0x%x greenlet=%r>) __class__ __module____name__r'rAr@r)r)r*__repr__s z_ThreadHandle.__repr__)rB)T)rSrR __qualname__r;r>r3r5rArDpropertyrLrHrPrTr)r)r)r*rs    rcGst}|t|S)z Called on 3.13 after forking in the child. Takes ``(module, ident)``, returns a handle object with that ident. )rr5r)r9r6r)r)r*rs rcsJeZdZdZejZer eZej Z fddZ e ddZ d dd ZZS) rz The basic lock type. .. versionchanged:: 24.10.1 Subclassing this object is no longer allowed. This matches the Python 3 API. cstdS)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)superr;r@rQr)r*r; szLockType.__init__cCtr&) TypeError)clsr)r)r*__init_subclass__szLockType.__init_subclass__TrBcCs|dkrd}|s|durtd|dur%|dkrtd||jkr%tdz t|||}Wnty<|r8d}Ynw|sJ|sJtturJt|S)NrBz/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#rrr)r8blockingrIacquiredr)r)r*r`s&      zLockType.acquire)TrB)rSrRrU__doc__ __thread__r_OVER_RELEASE_ERRORrr4rr^r; classmethodr\r` __classcell__r)r)rXr*rs   rcCrYr&rr)r)r)r*rJsrrcCs$|durtS|tkrt|SdSr&)_original_stack_size)sizer)r)r*rQs  ) only_namesignore_missing_namesrr&)r)NrM)-rcsys version_info__implements__ __imports__rrd __target__appendrGrgevent._compatr gevent._utilr gevent.hubrrrgevent._hub_localrgevent.greenletr gevent.lockr! gevent.localr"rgevent.exceptionsr#rr0rr rrrrr rrrhremoveglobals__all__r)r)r)r*s`                       'g O