<|hdZddlmZddlmZddlmZddlZddlmZddl m Z dgZ e Z ed jed <d ed <Gd de ZGddeZdZeddlmZeedy)z Low-level waiting primitives. )absolute_import)division)print_functionN)get_hub_noargs)ConcurrentObjectUseErrorWaitergreenlet getcurrentcyNr M/var/www/html/test/engine/venv/lib/python3.12/site-packages/gevent/_waiter.pyrsr greenlet_initcfeZdZdZgdZddZdZdZdZdZ e d Z d Z d Z d Zd ZdZy)ra: A low level communication utility for greenlets. Waiter is a wrapper around greenlet's ``switch()`` and ``throw()`` calls that makes them somewhat safer: * switching will occur only if the waiting greenlet is executing :meth:`get` method currently; * any error raised in the greenlet is handled inside :meth:`switch` and :meth:`throw` * if :meth:`switch`/:meth:`throw` is called before the receiver calls :meth:`get`, then :class:`Waiter` will store the value/exception. The following :meth:`get` will return the value/raise the exception. The :meth:`switch` and :meth:`throw` methods must only be called from the :class:`Hub` greenlet. The :meth:`get` method must be called from a greenlet other than :class:`Hub`. >>> from gevent.hub import Waiter >>> from gevent import get_hub >>> result = Waiter() >>> timer = get_hub().loop.timer(0.1) >>> timer.start(result.switch, 'hello from Waiter') >>> result.get() # blocks for 0.1 seconds 'hello from Waiter' >>> timer.close() If switch is called before the greenlet gets a chance to call :meth:`get` then :class:`Waiter` stores the value. >>> from gevent.time import sleep >>> result = Waiter() >>> timer = get_hub().loop.timer(0.1) >>> timer.start(result.switch, 'hi from Waiter') >>> sleep(0.2) >>> result.get() # returns immediately without blocking 'hi from Waiter' >>> timer.close() .. warning:: This is a limited and dangerous way to communicate between greenlets. It can easily leave a greenlet unscheduled forever if used incorrectly. Consider using safer classes such as :class:`gevent.event.Event`, :class:`gevent.event.AsyncResult`, or :class:`gevent.queue.Queue`. )hubr value _exceptionNc\| tn||_d|_d|_t|_yr )get_hubrr r_NONErselfrs r__init__zWaiter.__init__Is& # 79  rc6d|_d|_t|_yr )r rrrrs rclearz Waiter.clearOs  rcV|jtur&dt|jd|jdS|j3dt|jd|jd|j dSdt|jd|jd|j dS)Nz value=z exc_info=)rrtype__name__r rexc_infors r__str__zWaiter.__str__Tsz ??e #)-d)<)s||~>s A1Bc$|j|Sr )r/)rargss r switch_argszWaiter.switch_args~s{{4  rc|j}|||_yt|jur t d|j } ||y#|jj |gtjYyxYw)zWSwitch to the greenlet with the exception. If there's no greenlet, store the exception.Nr-) r rr rr.throwr0r1r$)r throw_argsr r6s rr6z Waiter.throwsn==  (DO|488+$%^__NNE >z" >%%%e=clln=s A 1A>c\|jtur:|j |jStj|jy|j t d|j t|_ |jjd|_S#d|_wxYw)zbIf a value/an exception is stored, return/raise it. Otherwise until switch() or throw() is called.NzThis Waiter is already used by ) rrrr r6r rrr/rs rgetz Waiter.gets ??% '&zz! JL   0}}(.VZVcVc/fgg&LDM %xx( $  s B"" B+c|j|j|jy|j|jyr ) exceptionr/rr6)rsources r__call__zWaiter.__call__s0    # KK % JJv'' (rr )r# __module__ __qualname____doc__ __slots__rrr%r(r*propertyr$r/r4r6r9r=r rrrrsV)V;I  d,'## ?*! > %)rc*eZdZdZdgZddZdZdZy)MultipleWaitera: An internal extension of Waiter that can be used if multiple objects must be waited on, and there is a chance that in between waits greenlets might be switched out. All greenlets that switch to this waiter will have their value returned. This does not handle exceptions or throw methods. _valuesNc>tj||g|_yr )rrrErs rrzMultipleWaiter.__init__sc"  rcf|jj|tj|dy)NT)rEappendrr/)rrs rr/zMultipleWaiter.switchs" E" dD!rc|js*tj|tj||jj dS)Nr)rErr9rpoprs rr9zMultipleWaiter.gets6|| JJt  LL ||""rr )r#r>r?r@rArr/r9r rrrDrDs I"#rrDctyr )rr rr_initrLsOr)import_c_accelzgevent.__waiter)r@ __future__rrrr1gevent._hub_localrrgevent.exceptionsr__all__objectr __import__r localsrrDrL gevent._utilrMglobalsr rrrWs'% 76   #J/::(G)VG)\#V#>(wy+,r