调度带有事件循环参数的函数调用

Question

您将如何调用带有参数的函数（在我的代码中称为 func）作为 event_loop 的一部分？考虑到这些函数应该在服务器传入请求时多次调用。

async def my_func_1(json_message: dict, writer: StreamWriter) -> bool:

    return True

async def my_func_2(json_message: dict, writer: StreamWriter) -> bool:

    return True

async def my_func_3(json_message: dict, writer: StreamWriter) -> bool:

    return True

switcher = {

    "Forward": my_func_1,

    "Backward": my_func_2,

    "Up": my_func_3

}

async def dispatcher(reader: StreamReader, writer: StreamWriter):

    try:

        msg = await reader.readline()

        message = ujson.decode(msg.decode())

    except Exception:

        print("unable to parse json from read stream:" + str(msg.decode()))

    

    if "method" in message:

        func = switcher.get(message['method'], UnknownMethod)

        # how would you invoke func with arguments as part of the event_loop?

        # considering these functions should be invoked multiple times.

def init():

    loop = asyncio.get_event_loop()

    coro = asyncio.start_server(dispatcher, '127.0.0.1', 666, loop=loop)

    server = loop.run_until_complete(coro)

    

    try:

        loop.run_forever()

    except KeyboardInterrupt:

        pass

    # Close the server

    server.close()

    loop.run_until_complete(server.wait_closed())

    loop.close()

if __name__ == '__main__':

    init()

感谢所有的帮助

Answer 1

根据我对您问题的理解，答案是简单地使用所需参数调用该函数，就像在任何其他上下文中一样。# ...if "method" in message:    func = switcher.get(message['method'], UnknownMethod)    await func(message, writer)# ...