如何在 python 中多处理 async/await 函数？

Question

我需要每 60 秒为我的所有汽车举办一次活动。我对下面代码的问题是while循环直到超时（60）才结束，因此只有汽车中的第一辆车在运行。

class RunCars(BaseEvent):

    def __init__(self):
        interval_seconds = 60  # Set the interval for this event
        super().__init__(interval_seconds)

    # run() method will be called once every {interval_seconds} minutes
    async def run(self, client, cars):
        for car in cars:        
            channel = get_channel(client, "general")
            await client.send_message(channel, 'Running this '+str(car))
            await msg.add_reaction(str(get_emoji(':smiley:'))) 
            
            reaction = None
            while True:
                if str(reaction) == str(get_emoji(':smiley:'))
                    await client.send_message(channel, 'Finished with this '+str(car))
                try:
                    reaction, user = await client.wait_for('reaction_add', timeout=60, check=check)
                except:
                    break

我尝试将代码更改为多线程进程，但在函数内部的 async/await 和 pickle 函数本身存在问题。

如果您有任何关于如何解决此问题的建议，我将不胜感激。

Answer 1

asyncio 模块允许您使用gather 方法同时执行多个async 方法。我认为您可以通过定义一个运行单个汽车的方法来实现您想要的行为，然后将您的for-loop 替换为对gather 的调用，这将同时执行多个run_one 协程（方法）：

import asyncio

class RunCars(BaseEvent):

    def __init__(self):
        interval_seconds = 60  # Set the interval for this event
        super().__init__(interval_seconds)


    async def run(self, client, cars):
        coroutines = [self.run_one(client, car) for car in cars]
        asyncio.gather(*coroutines)

    async def run_one(self, client, car):
        channel = get_channel(client, "general")
        await client.send_message(channel, 'Running this '+str(car))
        await msg.add_reaction(str(get_emoji(':smiley:'))) 
          
        reaction = None
        while True:
            if str(reaction) == str(get_emoji(':smiley:'))
                await client.send_message(channel, 'Finished with this '+str(car))
            try:
                reaction, user = await client.wait_for('reaction_add', timeout=60, check=check)
            except:
                break

一般来说，在编写异步代码时，您应该尝试用gather 语句替换对async 方法的顺序调用（基本上是调用async 方法的for-循环），以便它们同时执行。