我正在使用 aiohttp 来构建API服务器,该服务器将TCP请求发送到单独的服务器服务器。发送TCP请求的模块是同步的,对于我来说是一个黑匣子。所以我的问题是这些请求阻止了整个API。我需要一种将模块请求包装在异步协程中的方法,该协程不会阻塞API的其余部分。
I'm using aiohttp to build an API server that sends TCP requests off to a seperate server. The module that sends the TCP requests is synchronous and a black box for my purposes. So my problem is that these requests are blocking the entire API. I need a way to wrap the module requests in an asynchronous coroutine that won't block the rest of the API.
因此,只需使用 sleep 作为一个简单的示例,有什么方法可以将耗时的同步代码包装在一个非阻塞的协程中,就像这样:
So, just using sleep as a simple example, is there any way to somehow wrap time-consuming synchronous code in a non-blocking coroutine, something like this:
async def sleep_async(delay): # After calling sleep, loop should be released until sleep is done yield sleep(delay) return 'I slept asynchronously'推荐答案
最终我在此线程。我正在寻找的方法是 run_in_executor 。这允许同步函数异步运行而不会阻塞事件循环。
Eventually I found an answer in this thread. The method I was looking for is run_in_executor. This allows a synchronous function to be run asynchronously without blocking an event loop.
在上面发布的 sleep 示例中,则可能看起来像这样:
In the sleep example I posted above, it might look like this:
import asyncio from time import sleep async def sleep_async(loop, delay): # None uses the default executor (ThreadPoolExecutor) await loop.run_in_executor(None, sleep, delay) return 'I slept asynchronously'另请参阅以下答案->
Also see the following answer -> How do we call a normal function where a coroutine is expected?
更多推荐
如何在异步协程中包装同步函数?
发布评论