asyncio.Semaphore RuntimeError：任务将Future附加到另一个循环

asyncio.Semaphore RuntimeError：任务将Future附加到另一个循环

这是因为Semaphore构造函数

_loop

在asyncio /
locks.py中
设置了其属性：

class Semaphore(_ContextManagerMixin):    def __init__(self, value=1, *, loop=None):        if value < 0: raise ValueError("Semaphore initial value must be >= 0")        self._value = value        self._waiters = collections.deque()        if loop is not None: self._loop = loop        else: self._loop = events.get_event_loop()

但是

asyncio.run()

开始了一个全新的循环–在asyncio /
runners.py中
，它在文档中也有提及：

def run(main, *, debug=False):    if events._get_running_loop() is not None:        raise RuntimeError( "asyncio.run() cannot be called from a running event loop")    if not coroutines.iscoroutine(main):        raise ValueError("a coroutine was expected, got {!r}".format(main))    loop = events.new_event_loop()    ...

Semaphore

在外部发起

asyncio.run()

的获取异步“默认”循环，因此不能与通过创建的事件循环一起使用

asyncio.run()

。

解

Semaphore

从调用的代码开始

asyncio.run()

。您将必须将它们传递到正确的位置，如何执行此 *** 作的可能性更多，例如可以使用contextvars，但我仅给出最简单的示例：

import asyncioasync def work(sem):    async with sem:        print('working')        await asyncio.sleep(1)async def main():    sem = asyncio.Semaphore(2)    await asyncio.gather(work(sem), work(sem), work(sem))asyncio.run(main())

同样的问题（和解决方案）可能也有

asyncio.Lock

，

asyncio.Event

和

asyncio.Condition

。