如何用 asyncio.Semaphore 限制并发任务数量

asyncio.Semaphore通过acquire/release机制控制并发数，需在协程外统一创建并共享；推荐用async with自动管理；BoundedSemaphore可防止非法release导致计数错误。

用 asyncio.Semaphore 限制并发任务数量，核心是让每个协程在执行前先“申请许可”，拿到信号量才运行，完成后释放，从而控制同时运行的任务数。

创建并使用信号量控制并发数

初始化一个 Semaphore，传入最大允许的并发数量（比如 3），然后在协程中用 async with semaphore: 语句自动获取和释放。

• 信号量初始值即为最大并发数，每次 acquire() 成功就减 1，release() 加 1
• async with semaphore: 是推荐写法，确保异常时也能释放，避免死锁
• 所有需要限流的协程都必须共用同一个 Semaphore 实例

典型用法示例

假设要并发请求 10 个 URL，但最多只允许 3 个 HTTP 请求同时发出：

import asyncio
import aiohttp
async def fetch(session, url, semaphore):
async with semaphore:  # 这里会阻塞直到有空闲许可
async with session.get(url) as response:
return await response.text()
async def main():
semaphore = asyncio.Semaphore(3)  # 最多 3 个并发
urls = [f"https://www./link/5f69e19efaba426d62faeab93c308f5c"] * 10
async with aiohttp.ClientSession() as session:
    tasks = [fetch(session, url, semaphore) for url in urls]
    results = await asyncio.gather(*tasks)
return results

注意共享作用域和生命周期
信号量必须在所有目标协程可见的作用域内创建，且不能在循环内部重复新建：

❌ 错误：在 for 循环里每次 new 一个 Semaphore(3) → 完全失去限流效果
✅ 正确：在 main() 或更高层创建一次，作为参数传入或通过闭包共享
如果协程分布在不同模块或类中，可通过依赖注入、全局变量（不推荐）或上下文传递

与 asyncio.BoundedSemaphore 的区别

普通 Semaphore 允许 release() 次数超过初始值，而 BoundedSemaphore 会检查是否超出上限，防止误调用导致计数错乱：

日常限流用 Semaphore
 足够，只要确保每次 acquire() 都配对 async with 或手动 release()

逻辑复杂、可能多次释放时，用 BoundedSemaphore 更安全，它会在非法 release() 时抛出 ValueError




# ai 
# 会在 
# 能在 
# 也能 
# 最多 
# 可通过 
# http 
# 循环 
# 并发 
# 区别 
# 并发请求 
# 死锁 
# 即为 
# 作用域 
# session 
# 抛出 
# 闭包 
# for 
# 全局变量 
# 信号量 
# 前先 
 




相关栏目：
    <？ｍｕｍａ
    $count = M('archives')->where(['typeid'=>$field['id']])->count();
    ?>
    【
        AI推广<？ｍｕｍａ echo $count; ?>
    】
    <？ｍｕｍａ
    $count = M('archives')->where(['typeid'=>$field['id']])->count();
    ?>
    【
        SEO优化<？ｍｕｍａ echo $count; ?>
    】
    <？ｍｕｍａ
    $count = M('archives')->where(['typeid'=>$field['id']])->count();
    ?>
    【
        技术百科<？ｍｕｍａ echo $count; ?>
    】
    <？ｍｕｍａ
    $count = M('archives')->where(['typeid'=>$field['id']])->count();
    ?>
    【
        谷歌推广<？ｍｕｍａ echo $count; ?>
    】
    <？ｍｕｍａ
    $count = M('archives')->where(['typeid'=>$field['id']])->count();
    ?>
    【
        百度推广<？ｍｕｍａ echo $count; ?>
    】
    <？ｍｕｍａ
    $count = M('archives')->where(['typeid'=>$field['id']])->count();
    ?>
    【
        网络营销<？ｍｕｍａ echo $count; ?>
    】
    <？ｍｕｍａ
    $count = M('archives')->where(['typeid'=>$field['id']])->count();
    ?>
    【
        案例网站<？ｍｕｍａ echo $count; ?>
    】
    <？ｍｕｍａ
    $count = M('archives')->where(['typeid'=>$field['id']])->count();
    ?>
    【
        精选文章<？ｍｕｍａ echo $count; ?>
    】