0

0

asyncio.timeout() 在 3.11+ 如何与 gather/wait 配合使用

冰川箭仙

冰川箭仙

发布时间:2026-01-25 20:47:52

|

742人浏览过

|

来源于php中文网

原创

asyncio.timeout() 是上下文管理器而非超时参数,须用 async with 包裹 gather() 或 wait();超时触发时自动取消未完成任务,但要求协程支持取消,否则无法强制终止。

asyncio.timeout() 在 3.11+ 如何与 gather/wait 配合使用

asyncio.timeout() 不能直接传给 gather() 或 wait()

它不是超时参数,而是上下文管理器或异步生成器。常见错误是写成 asyncio.gather(..., timeout=asyncio.timeout(5)) —— 这会报 TypeError: gather() got an unexpected keyword argument 'timeout'。正确做法是把 gather()wait() 整个包进 asyncio.timeout()作用域里。

用 async with asyncio.timeout() 包裹 gather()

这是最直观、推荐的组合方式。超时触发时,所有正在运行的子协程会被取消(前提是它们能响应取消):

async def fetch_user(user_id):
    await asyncio.sleep(2)
    return f"user_{user_id}"

async def main(): try: async with asyncio.timeout(3): results = await asyncio.gather( fetch_user(1), fetch_user(2), fetch_user(3) ) print(results) except asyncio.TimeoutError: print("至少一个任务超时了,整个 gather 被中断")

  • asyncio.timeout() 在超时时刻抛出 asyncio.TimeoutError,并自动调用 cancel() 所有未完成的 Task
  • gather() 包裹的协程必须支持取消(比如不阻塞在纯同步 I/O 或没做 shield()
  • 如果某个子协程内部已处理了 CancelledError 且没重新抛出,gather() 可能不会立即失败,但超时上下文仍会退出

wait() 配合 timeout() 时要注意 done/pending 分离

asyncio.wait() 返回 (done, pending),而 asyncio.timeout() 不改变这个行为。你得手动检查 pending 是否非空:

梅子Ai论文
梅子Ai论文

无限免费生成千字论文大纲-在线快速生成论文初稿-查重率10%左右

下载
tasks = [asyncio.create_task(fetch_user(i)) for i in range(3)]
try:
    async with asyncio.timeout(2.5):
        done, pending = await asyncio.wait(tasks, return_when=asyncio.FIRST_COMPLETED)
    # 此时 pending 可能还有未完成的任务
    for t in pending:
        t.cancel()
except asyncio.TimeoutError:
    # 所有剩余 task 已被 cancel,但需 await 它们以清理状态
    await asyncio.gather(*pending, return_exceptions=True)
  • wait()return_when 参数决定何时返回,timeout() 只控制整体等待上限
  • pending 中的 task 不会自动 await,必须显式 cancel() + await gather(..., return_exceptions=True) 避免 “task was destroyed but it is pending!” 警告
  • 若用 return_when=asyncio.ALL_COMPLETEDpending 为空,但超时仍会提前跳出

嵌套 timeout() 或与 shield() 冲突要小心

如果你在子协程里也用了 asyncio.timeout(),外层超时会优先触发并取消内层;而 asyncio.shield() 会让被保护的协程忽略外层取消 —— 这可能导致 gather() 卡住或超时不生效:

  • 避免对单个子任务用 shield() 后再丢进带 timeout()gather()
  • 想给不同任务设不同超时?别嵌套 timeout(),改用 wait_for(task, timeout=...) 单独包装每个任务,再 gather() 这些 wait_for() 调用
  • wait_for()timeout() 不兼容混用:前者返回值,后者是上下文;混用容易漏掉取消传播

真正难处理的是那些不响应取消的协程(比如调用了阻塞的 time.sleep() 或没加 await 的 CPU 密集循环),这种情况下 timeout() 无法强制终止,只能等它自己结束。

热门AI工具

更多
DeepSeek
DeepSeek

幻方量化公司旗下的开源大模型平台

豆包大模型
豆包大模型

字节跳动自主研发的一系列大型语言模型

通义千问
通义千问

阿里巴巴推出的全能AI助手

腾讯元宝
腾讯元宝

腾讯混元平台推出的AI助手

文心一言
文心一言

文心一言是百度开发的AI聊天机器人,通过对话可以生成各种形式的内容。

讯飞写作
讯飞写作

基于讯飞星火大模型的AI写作工具,可以快速生成新闻稿件、品宣文案、工作总结、心得体会等各种文文稿

即梦AI
即梦AI

一站式AI创作平台,免费AI图片和视频生成。

ChatGPT
ChatGPT

最最强大的AI聊天机器人程序,ChatGPT不单是聊天机器人,还能进行撰写邮件、视频脚本、文案、翻译、代码等任务。

相关专题

更多
拼多多赚钱的5种方法 拼多多赚钱的5种方法
拼多多赚钱的5种方法 拼多多赚钱的5种方法

在拼多多上赚钱主要可以通过无货源模式一件代发、精细化运营特色店铺、参与官方高流量活动、利用拼团机制社交裂变,以及成为多多进宝推广员这5种方法实现。核心策略在于通过低成本、高效率的供应链管理与营销,利用平台社交电商红利实现盈利。

2

2026.01.26

edge浏览器怎样设置主页 edge浏览器自定义设置教程
edge浏览器怎样设置主页 edge浏览器自定义设置教程

在Edge浏览器中设置主页,请依次点击右上角“...”图标 > 设置 > 开始、主页和新建标签页。在“Microsoft Edge 启动时”选择“打开以下页面”,点击“添加新页面”并输入网址。若要使用主页按钮,需在“外观”设置中开启“显示主页按钮”并设定网址。

6

2026.01.26

苹果官方查询网站 苹果手机正品激活查询入口
苹果官方查询网站 苹果手机正品激活查询入口

苹果官方查询网站主要通过 checkcoverage.apple.com/cn/zh/ 进行,可用于查询序列号(SN)对应的保修状态、激活日期及技术支持服务。此外,查找丢失设备请使用 iCloud.com/find,购买信息与物流可访问 Apple (中国大陆) 订单状态页面。

15

2026.01.26

npd人格什么意思 npd人格有什么特征
npd人格什么意思 npd人格有什么特征

NPD(Narcissistic Personality Disorder)即自恋型人格障碍,是一种心理健康问题,特点是极度夸大自我重要性、需要过度赞美与关注,同时极度缺乏共情能力,背后常掩藏着低自尊和不安全感,影响人际关系、工作和生活,通常在青少年时期开始显现,需由专业人士诊断。

3

2026.01.26

windows安全中心怎么关闭 windows安全中心怎么执行操作
windows安全中心怎么关闭 windows安全中心怎么执行操作

关闭Windows安全中心(Windows Defender)可通过系统设置暂时关闭,或使用组策略/注册表永久关闭。最简单的方法是:进入设置 > 隐私和安全性 > Windows安全中心 > 病毒和威胁防护 > 管理设置,将实时保护等选项关闭。

4

2026.01.26

2026年春运抢票攻略大全 春运抢票攻略教你三招手【技巧】
2026年春运抢票攻略大全 春运抢票攻略教你三招手【技巧】

铁路12306提供起售时间查询、起售提醒、购票预填、候补购票及误购限时免费退票五项服务,并强调官方渠道唯一性与信息安全。

19

2026.01.26

个人所得税税率表2026 个人所得税率最新税率表
个人所得税税率表2026 个人所得税率最新税率表

以工资薪金所得为例,应纳税额 = 应纳税所得额 × 税率 - 速算扣除数。应纳税所得额 = 月度收入 - 5000 元 - 专项扣除 - 专项附加扣除 - 依法确定的其他扣除。假设某员工月工资 10000 元,专项扣除 1000 元,专项附加扣除 2000 元,当月应纳税所得额为 10000 - 5000 - 1000 - 2000 = 2000 元,对应税率为 3%,速算扣除数为 0,则当月应纳税额为 2000×3% = 60 元。

9

2026.01.26

oppo云服务官网登录入口 oppo云服务登录手机版
oppo云服务官网登录入口 oppo云服务登录手机版

oppo云服务https://cloud.oppo.com/可以在云端安全存储您的照片、视频、联系人、便签等重要数据。当您的手机数据意外丢失或者需要更换手机时,可以随时将这些存储在云端的数据快速恢复到手机中。

13

2026.01.26

抖币充值官方网站 抖币性价比充值链接地址
抖币充值官方网站 抖币性价比充值链接地址

网页端充值步骤:打开浏览器,输入https://www.douyin.com,登录账号;点击右上角头像,选择“钱包”;进入“充值中心”,操作和APP端一致。注意:切勿通过第三方链接、二维码充值,谨防受骗

6

2026.01.26

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
Go 教程
Go 教程

共32课时 | 4.2万人学习

Go语言实战之 GraphQL
Go语言实战之 GraphQL

共10课时 | 0.8万人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号