asyncio执行结果不符合预期，任务切换逻辑实现求助

Hey there! 看起来你踩中了asyncio协作式多任务的常见坑——想让任务中途切换，但没给事件循环“接手”的机会，导致secondaryTask()根本没在你期望的时机执行对吧？

先帮你梳理核心问题：asyncio不是抢占式的，只有当当前任务遇到await（或者其他可等待对象）时，事件循环才会暂停当前任务，去执行其他待运行的任务。如果你的代码里没有正确用await让出控制权，summation()会一口气跑完，secondaryTask()要么完全没执行，要么等summation()结束才启动，自然得不到预期结果。

先还原你的错误代码（大概率是这样） #

我猜你的代码大概是这个样子（补全你没贴完的部分）：

import asyncio

async def summation():
    total = 0
    for i in range(1, 51):
        total += i
        # 想在这里切换到secondaryTask，但写法错了
        if i == 10:
            secondaryTask()  # 只创建了协程对象，没执行也没让出控制权
    return total

async def secondaryTask():
    mul = 1
    for i in range(1, 5):
        mul *= i
    return mul

async def main():
    sum_res = await summation()
    mul_res = await secondaryTask()
    print(f"sum={sum_res}, mul={mul_res}")

asyncio.run(main())

这个代码的问题：

1. 调用secondaryTask()只返回协程对象，不会实际执行
2. main()里是顺序await两个任务，secondaryTask()要等summation()跑完才会开始，完全达不到“中途切换”的效果

正确实现中途切换的两种写法 #

写法1：在summation中主动await secondaryTask #

如果希望summation()执行到i=10时，立刻暂停去把secondaryTask()执行完，再回来继续跑，代码可以这么改：

import asyncio

async def summation():
    total = 0
    # 先创建secondaryTask的协程对象
    secondary_coro = secondaryTask()
    for i in range(1, 51):
        total += i
        if i == 10:
            # 这里用await，主动让出控制权，让事件循环执行secondary_coro
            mul_res = await secondary_coro
            print(f"中途完成secondaryTask，mul={mul_res}")
    return total

async def secondaryTask():
    mul = 1
    for i in range(1, 5):
        mul *= i
    return mul

async def main():
    sum_res = await summation()
    print(f"最终结果：sum={sum_res}, mul={24}")

asyncio.run(main())

运行这个代码，你会看到secondaryTask()在i=10时被触发执行，之后回到summation()继续计算，最终得到sum=1225、mul=24的预期结果。

写法2：用create_task创建后台任务，按需等待 #

如果想让secondaryTask()提前在后台启动，等summation()到指定点时再等它完成，也可以用asyncio.create_task：

import asyncio

async def summation():
    total = 0
    # 把secondaryTask变成后台任务，事件循环会自动调度它
    secondary_task = asyncio.create_task(secondaryTask())
    for i in range(1, 51):
        total += i
        if i == 10:
            # 等待后台任务完成
            mul_res = await secondary_task
            print(f"secondaryTask完成，mul={mul_res}")
    return total

async def secondaryTask():
    mul = 1
    for i in range(1, 5):
        mul *= i
    return mul

async def main():
    sum_res = await summation()
    print(f"最终结果：sum={sum_res}, mul={24}")

asyncio.run(main())

这种写法适合更复杂的并发场景，后台任务可以和summation()同时跑（如果secondaryTask()里有await的话），但你的需求里secondaryTask()是纯计算，所以两种写法效果差不多。

必记的asyncio知识点 #

• 协作式多任务：任务不会被强制打断，必须自己通过await让出控制权
• 协程对象≠执行：调用协程函数（比如secondaryTask()）只是创建对象，必须用await或者create_task交给事件循环才会执行
• 任务切换的时机：只有在await、asyncio.sleep()、asyncio.gather()等操作时，事件循环才会切换任务

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