diff options
author | Damien George <damien.p.george@gmail.com> | 2019-11-13 21:08:22 +1100 |
---|---|---|
committer | Damien George <damien.p.george@gmail.com> | 2020-03-26 01:25:45 +1100 |
commit | c4935f30490d0446e16a51dbf7a6397b771cf804 (patch) | |
tree | b095dd91914950939d4d0cdc10e7be3625fff00d /tests/extmod/uasyncio_event_fair.py | |
parent | 63b99443820f53afbdab5201044629d2bfecd73b (diff) | |
download | micropython-c4935f30490d0446e16a51dbf7a6397b771cf804.tar.gz micropython-c4935f30490d0446e16a51dbf7a6397b771cf804.zip |
tests/extmod: Add uasyncio tests.
All .exp files are included because they require CPython 3.8 which may not
always be available.
Diffstat (limited to 'tests/extmod/uasyncio_event_fair.py')
-rw-r--r-- | tests/extmod/uasyncio_event_fair.py | 40 |
1 files changed, 40 insertions, 0 deletions
diff --git a/tests/extmod/uasyncio_event_fair.py b/tests/extmod/uasyncio_event_fair.py new file mode 100644 index 0000000000..37eca5faef --- /dev/null +++ b/tests/extmod/uasyncio_event_fair.py @@ -0,0 +1,40 @@ +# Test fairness of Event.set() +# That tasks which continuously wait on events don't take over the scheduler + +try: + import uasyncio as asyncio +except ImportError: + try: + import asyncio + except ImportError: + print("SKIP") + raise SystemExit + + +async def task1(id): + for i in range(4): + print("sleep", id) + await asyncio.sleep(0) + + +async def task2(id, ev): + for i in range(4): + ev.set() + ev.clear() + print("wait", id) + await ev.wait() + + +async def main(): + ev = asyncio.Event() + tasks = [ + asyncio.create_task(task1(0)), + asyncio.create_task(task2(2, ev)), + asyncio.create_task(task1(1)), + asyncio.create_task(task2(3, ev)), + ] + await tasks[1] + ev.set() + + +asyncio.run(main()) |