你的websocket是多个连接吗?如果只有一个,这个recv/handle是异步的,效果和执行多
个read_from_websocket 一样
如果是多个,你可以用
tasks.append(read_from_websocket(uri[i]))
asyncio.gather(*tasks)
这样并行
【 在 migrant 的大作中提到: 】
: 我是希望
: async def read_from_websocket(uri):
: async with websockets.connect(uri) as websocket:
: ...................
--
FROM 119.139.197.*