U Ã@Ûfîã@sddlmZGdd„dƒZdS)é)Ú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|_t ¡|_|j ¡dS)Nr)ÚcounterÚ_eventÚEventrÚsend©Úself©r úH/var/www/html/chatgpt/venv/lib/python3.8/site-packages/eventlet/coros.pyÚ__init__s zmetaphore.__init__écCs2|dks t‚|j|7_|j|kr.|j ¡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 Zbyr r r Úincs  z metaphore.inccCs8|dks t‚|j|8_|jdkr4d|_|j ¡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)rrrrrr r r Údec*s   z metaphore.deccCs|j ¡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Úwaitrr r r r7szmetaphore.waitN)r )r )Ú__name__Ú __module__Ú __qualname__Ú__doc__r rrrr r r r rs  rN)Zeventletrrrr r r r Ús