Как из синхронной функции сделать асинхронную?

Question

[Михаил Ким]

Представим есть функция

def calc():
        i = 1
        while i < 100000000:
            i += 1
        return 'result'

Она синхронная и будет блокировать поток.

Можно выполнить ее в другом потоке:

from concurrent.futures import ThreadPoolExecutor, run_on_executor

executor = ThreadPoolExecutor(max_worker=4)

@run_on_executor
def calc():
        i = 1
        while i < 100000000:
            i += 1
        return 'result'

Но неужели синхронную функцию в Tornado можно превратить в асинхронную только так?

Comments

[iegor]

в tornado используются корутины, а не треды.

[Михаил Ким]

iegor: там используются и треды тоже. Корутины это не панацея, не магия, которая все одним async/await делает асинхронный. Корутиной Вы не сделаете абсолютно синхронную функцию (обработка фото, например) асинхронной

[Сергей Горностаев]

Михаил Ким: потоки используются только для операций дискового ввода/вывода, так как Python не умеет делать их асинхронными. Всё остальное нормально асинхронится с помощью async/await или @coroutine.

[Михаил Ким]

Сергей Горностаев: ну, например, у меня есть функция, в которой я использую бинарный скрипт:

def detect_face(photo):
process = subprocess.Popen(['./rcr-detect',
'-f', 'haarcascade_frontalface_alt2.xml',
'-m', 'face_landmarks_model_rcr_22.bin',
'-i', photo
], stdout=subprocess.PIPE, cwd='cv/detector')
out, _ = process.communicate()
return out

Как с помощью корутин сделать ее асинхронной? Извините, если глупый вопрос, документацию торнадо читал, несколько раз, но никак не могу разобраться

[Михаил Ким]

А, разобрался, есть tornado.process.subprocess