Method consumer

test/asynchronous/test_locks.py:374–381

()

            state = 0

            async def consumer():
                nonlocal state
                async with condition:
                    while True:
                        await condition.wait_for(lambda: state != 0)
                        if state < 0:
                            return
                        state -= 1

            # create two consumers
            c = [asyncio.create_task(consumer()) for _ in range(2)]