3 Z_ð]ã@s,ddlmZddlmZGdd„deƒZdS)é)Úprint_function)Úeventc@s4eZdZdZdd„Zd dd„Zd dd„Zd d „Zd S)Ú metaphoreaThis is sort of an inverse semaphore: a counter that starts at 0 and waits only if nonzero. It's used to implement a "wait for all" scenario. >>> from eventlet import coros, spawn_n >>> count = coros.metaphore() >>> count.wait() >>> def decrementer(count, id): ... print("{0} decrementing".format(id)) ... count.dec() ... >>> _ = spawn_n(decrementer, count, 'A') >>> _ = spawn_n(decrementer, count, 'B') >>> count.inc(2) >>> count.wait() A decrementing B decrementing cCsd|_tjƒ|_|jjƒdS)Nr)ÚcounterÚ_eventÚEventrÚsend)Úself©r ú2/tmp/pip-build-yz_zf6az/eventlet/eventlet/coros.pyÚ__init__s zmetaphore.__init__écCs2|dks t‚|j|7_|j|kr.|jjƒdS)z‰Increment our counter. If this transitions the counter from zero to nonzero, make any subsequent :meth:`wait` call wait. rN)ÚAssertionErrorrrÚreset)r Úbyr r r Úincs  z metaphore.inccCs8|dks t‚|j|8_|jdkr4d|_|jjƒdS)z–Decrement our counter. If this transitions the counter from nonzero to zero, a current or subsequent wait() call need no longer wait. rN)rrrr)r rr r r Údec,s   z metaphore.deccCs|jjƒdS)zŠSuspend the caller only if our count is nonzero. In that case, resume the caller once the count decrements to zero again. N)rÚwait)r r r r r9szmetaphore.waitN)r )r )Ú__name__Ú __module__Ú __qualname__Ú__doc__r rrrr r r r rs  rN)Ú __future__rZeventletrrÚobjectrr r r r Ús