mirror of
https://github.com/python/cpython.git
synced 2025-07-31 07:04:42 +00:00
bpo-37658: Actually return result in race condition (GH-29202)
(cherry picked from commit 934a826237
)
Co-authored-by: Sam Bull <aa6bs0@sambull.org>
This commit is contained in:
parent
8d1a580064
commit
305236e03a
3 changed files with 13 additions and 36 deletions
|
@ -1148,20 +1148,16 @@ class BaseTaskTests:
|
|||
self.assertEqual(res, "ok")
|
||||
|
||||
def test_wait_for_cancellation_race_condition(self):
|
||||
def gen():
|
||||
yield 0.1
|
||||
yield 0.1
|
||||
yield 0.1
|
||||
yield 0.1
|
||||
async def inner():
|
||||
with contextlib.suppress(asyncio.CancelledError):
|
||||
await asyncio.sleep(1)
|
||||
return 1
|
||||
|
||||
loop = self.new_test_loop(gen)
|
||||
async def main():
|
||||
result = await asyncio.wait_for(inner(), timeout=.01)
|
||||
assert result == 1
|
||||
|
||||
fut = self.new_future(loop)
|
||||
loop.call_later(0.1, fut.set_result, "ok")
|
||||
task = loop.create_task(asyncio.wait_for(fut, timeout=1))
|
||||
loop.call_later(0.1, task.cancel)
|
||||
res = loop.run_until_complete(task)
|
||||
self.assertEqual(res, "ok")
|
||||
asyncio.run(main())
|
||||
|
||||
def test_wait_for_waits_for_task_cancellation(self):
|
||||
loop = asyncio.new_event_loop()
|
||||
|
@ -1240,24 +1236,6 @@ class BaseTaskTests:
|
|||
with self.assertRaises(FooException):
|
||||
loop.run_until_complete(foo())
|
||||
|
||||
def test_wait_for_raises_timeout_error_if_returned_during_cancellation(self):
|
||||
loop = asyncio.new_event_loop()
|
||||
self.addCleanup(loop.close)
|
||||
|
||||
async def foo():
|
||||
async def inner():
|
||||
try:
|
||||
await asyncio.sleep(0.2)
|
||||
except asyncio.CancelledError:
|
||||
return 42
|
||||
|
||||
inner_task = self.new_task(loop, inner())
|
||||
|
||||
await asyncio.wait_for(inner_task, timeout=_EPSILON)
|
||||
|
||||
with self.assertRaises(asyncio.TimeoutError):
|
||||
loop.run_until_complete(foo())
|
||||
|
||||
def test_wait_for_self_cancellation(self):
|
||||
loop = asyncio.new_event_loop()
|
||||
self.addCleanup(loop.close)
|
||||
|
|
Loading…
Add table
Add a link
Reference in a new issue