o ;gZ)@sdZddlZgdejdddkrgdngZdgZddlZdZegd 7Zed e ed r7ed ej Z dd l m Z dd l mZddlmZddlmZddlmZddlmZddlmZddlmZddlmZddlmZe edredd-ddZd.ddZd.ddZ d/dd 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)0aK 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_idZdaemon_threads_allowed)PYPY) copy_globals) getcurrent GreenletExit)sleep)get_hub_if_exists)Greenlet)BoundedSemaphore)local)LoopExitRLockcCs|durt}t|SN)rid)Zgrr&T/home/www/bk.finsightngr.online/venv20/lib/python3.10/site-packages/gevent/thread.pyrJsrr&cCs:|durtj|g|Ri|}|Stj|g|R}|Sr$)rspawn)functionargskwargsgreenletr&r&r'_start_new_greenletPs r-cCstt|||Sr$)rr-)r)r*r+r&r&r'rWsrTcCs,t|}|durt|tsJ|||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. N)r- isinstancer _set_greenlet)r)handledaemonr,r&r&r'r Zs  r c@sVeZdZddZdZddZddZdd Zed d Z d d Z dddZ ddZ dS)rcOsdS)zDoes nothing; ignores argsNr&)self_args_kwargsr&r&r'__init__~sz_ThreadHandle.__init__NcCs&ddlm}|dus J|||_dS)Nr)ref)weakrefr6 _greenlet_ref)r2gletr6r&r&r'r/s  z_ThreadHandle._set_greenletcCs|jdur |SdSr$)r8r2r&r&r' _get_greenlets z_ThreadHandle._get_greenletcCs|}|durA|turtdt|dr||Sddlm}d}|r*||}|sA|dur9||kr9dStd|r.dS)NzCannot joint current threadjoinr)timeMbP?)r;r RuntimeErrorhasattrr<r=is_doner)r2timeoutr9r=endr&r&r'r<s      z_ThreadHandle.joincCs|}|dur t|SdSr$)r;rr2r9r&r&r'identsz_ThreadHandle.identcCs|}|dur dS|jSNT)r;ZdeadrDr&r&r'rAsz_ThreadHandle.is_doneTcCsd|_|r tddSdS)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. Nr>)r8r)r2Z 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%r;r:r&r&r'__repr__s z_ThreadHandle.__repr__)T) rJrI __qualname__r5r8r/r;r<propertyrErArGrKr&r&r&r'r{s   rcGst}|t|S)z Called on 3.13 after forking in the child. Takes ``(module, ident)``, returns a handle object with that ident. )rr/r)r3r0r&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)superr5r:rHr&r'r5szLockType.__init__cCtr$) TypeError)clsr&r&r'__init_subclass__szLockType.__init_subclass__TcCs|dkrd}|s|durtd|dur%|dkrtd||jkr%tdz t|||}Wnty<|r8d}Ynw|sJ|sJtturJt|S)NrTz/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)r2blockingrBZacquiredr&r&r'rXs&      zLockType.acquire)TrT)rJrIrL__doc__ __thread__rZ_OVER_RELEASE_ERRORrr?rrVr5 classmethodrSrX __classcell__r&r&rOr'rs   rcCrPr$rr&r&r&r'r1srrcCs$|durtS|tkrt|SdSr$)_original_stack_size)sizer&r&r'r8s  )Z only_namesZignore_missing_namesrr$)r&NrF)-rZsys version_infoZ__implements__Z __imports__rr[Z __target__appendr@rZgevent._compatrZ gevent._utilrZ gevent.hubrrrZgevent._hub_localrZgevent.greenletrZ gevent.lockr Z gevent.localr!rZgevent.exceptionsr"rr-rr rrrrr rrr^removeglobals__all__r&r&r&r's\                     !Y O