summaryrefslogtreecommitdiff
path: root/tests/extmod/uasyncio_gather.py
diff options
context:
space:
mode:
authorDamien George <damien@micropython.org>2022-04-21 13:19:34 +1000
committerDamien George <damien@micropython.org>2022-04-21 14:25:17 +1000
commit28e7e15c0ad03f406cc5214f22d9a90a560f65c4 (patch)
treecb7e24ad6a2a54aba62c132b75c31a70b83bb2dc /tests/extmod/uasyncio_gather.py
parentf7454f850feaeef7f567e434205ad648192ba01b (diff)
extmod/uasyncio: Fix bug with task ending just after gather is cancel'd.
This fixes a bug where the gather is cancelled externally and then one of its sub-tasks (that the gather was waiting on) finishes right between the cancellation being queued and being executed. Signed-off-by: Damien George <damien@micropython.org>
Diffstat (limited to 'tests/extmod/uasyncio_gather.py')
-rw-r--r--tests/extmod/uasyncio_gather.py13
1 files changed, 11 insertions, 2 deletions
diff --git a/tests/extmod/uasyncio_gather.py b/tests/extmod/uasyncio_gather.py
index 366c113a2..fb47e753f 100644
--- a/tests/extmod/uasyncio_gather.py
+++ b/tests/extmod/uasyncio_gather.py
@@ -20,9 +20,9 @@ async def factorial(name, number):
return f
-async def task(id):
+async def task(id, t=0.02):
print("start", id)
- await asyncio.sleep(0.02)
+ await asyncio.sleep(t)
print("end", id)
return id
@@ -96,5 +96,14 @@ async def main():
t.cancel()
await asyncio.sleep(0.04)
+ # Test edge cases where the gather is cancelled just as tasks are created and ending.
+ for i in range(1, 4):
+ print("====")
+ t = asyncio.create_task(gather_task(task(1, t=0), task(2, t=0)))
+ for _ in range(i):
+ await asyncio.sleep(0)
+ t.cancel()
+ await asyncio.sleep(0.2)
+
asyncio.run(main())