Senkronize bir işlevi bir async coroutine'de nasıl kaydederim?

Question

TCP isteklerini ayrı bir sunucuya gönderen bir API sunucusu oluşturmak için aiohttp kullanıyorum. TCP isteklerini gönderen modül eşzamanlı ve amaçlarım için bir kara kutu. Yani benim sorunum, bu isteklerin tüm API'yi engellemesidir. Modül isteklerini, API'nın geri kalanını engellemeyen bir eşzamansız bir coroutine sarmak için bir yönteme ihtiyacım var.

async def sleep_async(delay): 
    # After calling sleep, loop should be released until sleep is done 
    yield sleep(delay) 
    return 'I slept asynchronously' 

Answer 1

Sonunda bir cevap buldum: sadece basit bir örnek olarak sleep kullanarak Yani

, nasılsa engellenmeyen eşyordamın içinde zaman alıcı senkron kodu sarmak için herhangi bir yolu, böyle bir şey yoktur this thread. Aradığım yöntem run_in_executor. Bu, bir senkronizasyon işlevinin bir olay döngüsünü engellemeden eşzamansız olarak çalıştırılmasına olanak tanır. Yukarıdaki haberi sleep örnekte

, bu gibi görünebilir:

import asyncio 
from time import sleep 
from concurrent.futures import ProcessPoolExecutor 

async def sleep_async(loop, delay): 
    # Can set executor to None if a default has been set for loop 
    await loop.run_in_executor(ProcessPoolExecutor(), sleep, delay) 
    return 'I slept asynchronously' 

Ayrıca şu cevabı bakın -> How do we call a normal function where a coroutine is expected? Hep I/O engelle