h6 NdZddlmZdZGddZGddZdS) z&Semaphores and concurrency primitives.)deque) DummyLockLaxBoundedSemaphorec@eZdZdZdZdZdZd dZd dZdZ d Z d S) raAsynchronous Bounded Semaphore. Lax means that the value will stay within the specified range even if released more times than it was acquired. Example: >>> x = LaxBoundedSemaphore(2) >>> x.acquire(print, 'HELLO 1') HELLO 1 >>> x.acquire(print, 'HELLO 2') HELLO 2 >>> x.acquire(print, 'HELLO 3') >>> x._waiters # private, do not access directly [print, ('HELLO 3',)] >>> x.release() HELLO 3 c|x|_|_t|_|jj|_|jj|_dSN) initial_valuevaluer_waitingappend _add_waiterpopleft _pop_waiter)selfr s X/var/www/html/Sam_Eipo/venv/lib/python3.11/site-packages/kombu/asynchronous/semaphore.py__init__zLaxBoundedSemaphore.__init__s<*//TZ =/=0c|j}|dkr||||fdSt|dz d|_||i|dS)aLAcquire semaphore. This will immediately apply ``callback`` if the resource is available, otherwise the callback is suspended until the semaphore is released. Arguments: callback (Callable): The callback to apply. *partial_args (Any): partial arguments to callback. rFT)r r max)rcallback partial_argspartial_kwargsr s racquirezLaxBoundedSemaphore.acquire%sc  A::   h nE F F F5UQY**DJ Hl 5n 5 5 54rc |\}}}||i|dS#t$r&t|jdz|j|_YdSwxYw)zRelease semaphore. Note: If there are any waiters this will apply the first waiter that is waiting for the resource (FIFO order). rN)r IndexErrorminr r )rwaiterargskwargss rreleasezLaxBoundedSemaphore.release9s} $#'#3#3#5#5 FD& FD #F # # # # # A A ATZ!^T-?@@DJJJJ As$,AArc~xj|z c_xj|z c_fdt|DdS)z6Change the size of the semaphore to accept more users.c8g|]}S)r!).0_rs r z,LaxBoundedSemaphore.grow..Ks!***A***rN)r r rangerns` rgrowzLaxBoundedSemaphore.growGsL a a ****q******rczt|j|z d|_t|j|z d|_dS)z6Change the size of the semaphore to accept less users.rN)rr r r)s rshrinkzLaxBoundedSemaphore.shrinkMs7 !3a!7;;a++ rcP|j|j|_dS)z@Reset the semaphore, which also wipes out any waiting callbacks.N)r clearr r rs rr/zLaxBoundedSemaphore.clearRs$ ' rcd|jjt||jt |jS)Nz!<{} at {:#x} value:{} waiting:{}>)format __class____name__idr lenr r0s r__repr__zLaxBoundedSemaphore.__repr__Ws:299 N #RXXtz3t};M;M   rN)r) r4 __module__ __qualname____doc__rrr!r+r-r/r7r$rrrrs,111 ( $ $ $++++ ,,,, (((      rrceZdZdZdZdZdS)rzPretending to be a lock.c|Srr$r0s r __enter__zDummyLock.__enter__`s rcdSrr$)rexc_infos r__exit__zDummyLock.__exit__cs rN)r4r8r9r:r=r@r$rrrr]s8""     rrN)r: collectionsr__all__rrr$rrrCs,, .R R R R R R R R j          r