summaryrefslogtreecommitdiffstatshomepage
path: root/tests/extmod/uasyncio_event_fair.py
diff options
context:
space:
mode:
authorDamien George <damien.p.george@gmail.com>2019-11-13 21:08:22 +1100
committerDamien George <damien.p.george@gmail.com>2020-03-26 01:25:45 +1100
commitc4935f30490d0446e16a51dbf7a6397b771cf804 (patch)
treeb095dd91914950939d4d0cdc10e7be3625fff00d /tests/extmod/uasyncio_event_fair.py
parent63b99443820f53afbdab5201044629d2bfecd73b (diff)
downloadmicropython-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.py40
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())