Python 异步编程 asyncio lock 如何让多个协程共享一把锁

先上代码：

import asyncio
import aioredis

# redis 池
redis_pool = {

}

# redis 池读写锁
_lock = asyncio.Lock()

async def get_db(index:str="0"):
    global redis_pool
    await _lock.acquire() # 请求锁
    db = redis_pool.get(index)
    print(db)
    if db is None:
        specify_db = await aioredis.create_redis_pool("redis://localhost",db=int(index))
        redis_pool.update({index:specify_db})
        _lock.release() # 更新 redis 池完毕，释放锁
        return specify_db
    
    _lock.release() # 不需要生成 redis 连接，立即释放锁
    return db


async def put_json(key:str,value:str,db_index:str="0",expire=-1):
    db = await get_db(db_index)
    await db.set(key,value,expire=expire)
    
async def test():
    t1 = asyncio.create_task(get_db("0"))
    t2 = asyncio.create_task(get_db("0"))
    t3 = asyncio.create_task(get_db("0"))
    t4 = asyncio.create_task(get_db("0"))
    t5 = asyncio.create_task(get_db("0"))
    task_list = [t1, t2, t3, t4, t5]
    await asyncio.wait(task_list)
    

if __name__ == '__main__':
    asyncio.get_event_loop().run_until_complete(test())

这是我构建了一个简易的 aioredis 连接池，如果单纯执行这个 test 的时候 lock 可以正确使用，但一旦其他异步代码通过 from import 调用put_json()那么get_db()就会抛出... got Future <Future pending> attached to a different loop,说lock.acquire()和 其他代码不再同一个事务循环中

而且查阅源码看到 asyncio.Lock()若不指定 loop 循环就会通过asyncio.get_event_loop()得到一个新循环，网上对于 asyncio.Lock 对象资料太少了。只有少量的 demo，demo 中是在 create_task 之前就创建好锁，然后参数传递给异步方法，这样做对 demo 有效，但对层次太多的代码很不友好

我现在的问题是我不想从 create_task()前就创建一把锁然后一直用参数传递到 get_db()中，因为这把锁只针对 redis_pool 的读写操作，其他代码根本不需要这把锁，还有有什么其他的办法可以调度协程对某个对象的读写吗