Python Asyncio数据竞争规避与顺序请求实现：事件循环报错问题咨询

我来帮你拆解一下这个问题，分几个核心方向入手，应该就能理清思路解决问题了：

1. 先搞定"事件循环已运行"的报错 #

你遇到的RuntimeError: This event loop is already running，本质是你试图在一个已经启动的事件循环里，再次手动调用run_until_complete()来启动循环。这种情况常见于：

• 交互式环境（比如Jupyter Notebook、IPython），它们会自动启动事件循环
• 基于asyncio的Web框架（比如FastAPI、Starlette），框架本身已经在管理事件循环

解决方法分两种场景：

• 普通Python脚本环境：用Python3.7+引入的asyncio.run()替代手动管理循环，它会自动创建、运行、关闭事件循环，不会有冲突：

  async def main():
      # 这里放你的业务逻辑
      pass
  
  asyncio.run(main())
  

• 已有事件循环的环境：直接await你的顶层协程函数就行，不用再手动调用run_until_complete()，比如在Jupyter里直接执行：

  await main()
  

2. 让请求严格按0→1→2…→9的顺序执行 #

你原来用asyncio.gather(*requests)是并发执行所有请求，所以完成顺序完全不保证，这和你要的顺序执行需求矛盾。要实现严格顺序，核心是串行执行每个请求——前一个请求完成后，再启动下一个：

修改后的代码示例 #

import asyncio

async def ordered_task(server):
    # 逐个循环await，保证前一个请求结束才启动下一个
    for value in range(10):
        result = await server.some_method(value)
        # 这里可以处理每个请求的结果，比如打印、存储
        print(f"Request {value} completed with result: {result}")

# 普通脚本里启动
asyncio.run(ordered_task(server))

# 已有循环的环境里直接await
# await ordered_task(server)

这样执行的话，server.some_method(0)完全执行完，才会开始server.some_method(1)，以此类推，天然保证了顺序。

3. 消除数据竞争问题 #

数据竞争的根源是多个协程同时访问/修改共享资源（比如全局变量、同一个对象的属性）。而上面的串行执行方式，因为同一时间只有一个协程在运行，不会有多个协程同时操作共享资源的情况，所以直接就消除了数据竞争。

如果之后你有需要并发但又要避免数据竞争的场景，可以用asyncio.Lock来保护共享资源：

lock = asyncio.Lock()

async def safe_operation(shared_data):
    async with lock:
        # 这里的代码同一时间只有一个协程能执行
        shared_data["count"] += 1

几个关键理解点 #

• 区分并发和串行：asyncio的gather、create_task是用来实现并发的，而顺序执行需要逐个await
• 事件循环的唯一性：一个线程里同一时间只能有一个事件循环在运行，不要重复启动
• 数据竞争的本质：共享资源的无保护并发访问，串行或锁是两种核心解决方案

内容的提问来源于stack exchange，提问作者Ryadas