使用aiomultiprocess遇AttributeError: enter错误，求解决方案

架构老林

2026-8-24

问题解决：aiomultiprocess Pool 报 AttributeError: enter 及相关问题

错误原因

aiomultiprocess的Pool类不支持上下文管理器协议（即无法使用with语句），这是触发AttributeError: __enter__的直接原因。此外代码还有两处潜在问题：

异步函数c中，index是整数类型，直接与字符串"c"拼接会触发类型错误
用同步函数main包裹异步调用，未充分利用aiomultiprocess的异步特性

修正方案

方案1：手动管理Pool的创建与关闭

既然无法使用with语句，就手动实例化Pool并调用close()和join()完成资源回收：

import asyncio
from aiomultiprocess import Pool


async def c(index):
    print(f"c{index}")  # 用f-string避免类型拼接错误


def main(index):
    print("b")
    asyncio.run(c(index))


if __name__ == "__main__":
    print("a")
    pool = Pool()
    pool.map(main, [i for i in range(2)])
    pool.close()
    pool.join()

方案2：充分利用aiomultiprocess的异步能力（推荐）

aiomultiprocess专为异步任务并行设计，可直接让Pool处理异步函数，无需额外同步包裹：

import asyncio
from aiomultiprocess import Pool


async def c(index):
    print(f"c{index}")
    print("b")  # 把原main的逻辑直接整合到异步函数中


async def main():
    print("a")
    pool = Pool()
    await pool.map(c, [i for i in range(2)])
    pool.close()
    await pool.join()


if __name__ == "__main__":
    asyncio.run(main())