cond.py

# coding: utf-8

import random

from simple_reactor import get_event_loop

loop = get_event_loop()

cond = loop.create_condition()

stack = []


async def func1():

    while 1:
        async with cond:
            print("func1 locked")

            while not stack:
                await cond.wait()

            assert cond.locked()
            assert len(stack) != 0

            stack.clear()
            cond.notify()

            print("func1 release")


async def func2():
    while 1:
        async with cond:
            print("func2 locked")
            while stack:
                await cond.wait()

            assert cond.locked()
            assert len(stack) == 0

            # do something
            await loop.sleep(2.5)

            stack.append(random.random())

            cond.notify()

            print("func2 release")


loop.run_coroutine_func(func2)

loop.run_coroutine_func(func1)

loop.loop_forever()