mirrors/cpython
1
0
Fork 0
mirror of https://github.com/python/cpython.git synced 2025-12-11 11:31:05 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 11

gH-80788: remove old weakset workaround for thread safety (#123388)

Browse source
This commit is contained in:
Kumar Aditya 2024-08-27 19:12:44 +05:30 • committed by GitHub
parent 03f5abf15a
commit 460ee5b994
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 2 additions and 17 deletions
Download patch file Download diff file Expand all files Collapse all files

19
Lib/asyncio/tasks.py
View file

@ -48,23 +48,8 @@ def all_tasks(loop=None):
# capturing the set of eager tasks first, so if an eager task "graduates" # capturing the set of eager tasks first, so if an eager task "graduates"
# to a regular task in another thread, we don't risk missing it. # to a regular task in another thread, we don't risk missing it.
eager_tasks = list(_eager_tasks) eager_tasks = list(_eager_tasks)
# Looping over the WeakSet isn't safe as it can be updated from another
# thread, therefore we cast it to list prior to filtering. The list cast return {t for t in itertools.chain(_scheduled_tasks, eager_tasks)
# itself requires iteration, so we repeat it several times ignoring
# RuntimeErrors (which are not very likely to occur).
# See issues 34970 and 36607 for details.
scheduled_tasks = None
i = 0
while True:
try:
scheduled_tasks = list(_scheduled_tasks)
except RuntimeError:
i += 1
if i >= 1000:
raise
else:
break
return {t for t in itertools.chain(scheduled_tasks, eager_tasks)
if futures._get_loop(t) is loop and not t.done()} if futures._get_loop(t) is loop and not t.done()}