ó O'—^c@@sbdZddlmZddlmZddgZdefd„ƒYZdefd„ƒYZdS( sV kombu.async.semaphore ===================== Semaphores and concurrency primitives. i(tabsolute_import(tdequet DummyLocktLaxBoundedSemaphorecB@sSeZdZd„Zd„Zd„Zdd„Zdd„Zd„Zd„Z RS( s`Asynchronous Bounded Semaphore. Lax means that the value will stay within the specified range even if released more times than it was acquired. Example: >>> from future import print_statement as printf # ^ ignore: just fooling stupid pyflakes >>> x = LaxBoundedSemaphore(2) >>> x.acquire(printf, 'HELLO 1') HELLO 1 >>> x.acquire(printf, 'HELLO 2') HELLO 2 >>> x.acquire(printf, 'HELLO 3') >>> x._waiters # private, do not access directly [print, ('HELLO 3', )] >>> x.release() HELLO 3 cC@s>||_|_tƒ|_|jj|_|jj|_dS(N(t initial_valuetvalueRt_waitingtappendt _add_waitertpopleftt _pop_waiter(tselfR((s7/tmp/pip-unpacked-wheel-UAnTfW/kombu/async/semaphore.pyt__init__,s cG@sT|j}|dkr,|j||fƒtSt|ddƒ|_||ŒtSdS(sÇAcquire semaphore, applying ``callback`` if the resource is available. :param callback: The callback to apply. :param \*partial_args: partial arguments to callback. iiN(RRtFalsetmaxtTrue(R tcallbackt partial_argsR((s7/tmp/pip-unpacked-wheel-UAnTfW/kombu/async/semaphore.pytacquire2s   cC@sTy|jƒ\}}Wn-tk rEt|jd|jƒ|_n X||ŒdS(s–Release semaphore. If there are any waiters this will apply the first waiter that is waiting for the resource (FIFO order). iN(R t IndexErrortminRR(R twaitertargs((s7/tmp/pip-unpacked-wheel-UAnTfW/kombu/async/semaphore.pytreleaseCs   icC@sE|j|7_|j|7_gt|ƒD]}|jƒ^q+dS(s6Change the size of the semaphore to accept more users.N(RRtrangeR(R tnt_((s7/tmp/pip-unpacked-wheel-UAnTfW/kombu/async/semaphore.pytgrowQscC@s6t|j|dƒ|_t|j|dƒ|_dS(s6Change the size of the semaphore to accept less users.iN(RRR(R R((s7/tmp/pip-unpacked-wheel-UAnTfW/kombu/async/semaphore.pytshrinkWscC@s|jjƒ|j|_dS(s@Reset the semaphore, which also wipes out any waiting callbacks.N(RtclearRR(R ((s7/tmp/pip-unpacked-wheel-UAnTfW/kombu/async/semaphore.pyR\s cC@s.dj|jjt|ƒ|jt|jƒƒS(Ns%<{0} at {1:#x} value:{2} waiting:{3}>(tformatt __class__t__name__tidRtlenR(R ((s7/tmp/pip-unpacked-wheel-UAnTfW/kombu/async/semaphore.pyt__repr__as( R t __module__t__doc__R RRRRRR#(((s7/tmp/pip-unpacked-wheel-UAnTfW/kombu/async/semaphore.pyRs      cB@s eZdZd„Zd„ZRS(sPretending to be a lock.cC@s|S(N((R ((s7/tmp/pip-unpacked-wheel-UAnTfW/kombu/async/semaphore.pyt __enter__jscG@sdS(N((R texc_info((s7/tmp/pip-unpacked-wheel-UAnTfW/kombu/async/semaphore.pyt__exit__ms(R R$R%R&R((((s7/tmp/pip-unpacked-wheel-UAnTfW/kombu/async/semaphore.pyRgs N( R%t __future__Rt collectionsRt__all__tobjectRR(((s7/tmp/pip-unpacked-wheel-UAnTfW/kombu/async/semaphore.pyts  W