Как использовать run_sync для торнадо Python при создании подпрограмм async?

Question

Я хотел бы запустить метод с run_sync для запуска торнадо IOLoop, который запускает асинхронные методы.

Вот идея:

@gen.coroutine 
def async(string): 
    print string 


@gen.coroutine 
def sync(): 
    string_list = yield async_call() 
    for string in string_list: 
     async(string=string) 

loop = IOLoop.current() 
loop.run_sync(lambda: sync) 

Так что, все в синхронизации должен происходить синхронно, но порядок, в котором асинхронный называются не имеет значения. Это возможно с торнадо?

Answer 1

Как я вижу, вы неправильно поняли смысл асинхронных вычислений. В двух словах, если у вас есть две функции, которые вы выполняете асинхронно в IOLoop, код каждой функции будет выполняться одновременно, но рабочий процесс функции будет по-прежнему синхронным.

При запуске async метод без yield ключевого слова вы должны быть уверены, что она заканчивается перед функцией вызывающей, особенно при использовании run_sync который останавливает IOLoop после функции остановилась. Это может привести к неопределенному поведению, когда async все еще работает, но IOLoop остановлен.

Я редактировал свой код, чтобы показать, что функция рабочего процесса sync «s выполняется синхронно:

@gen.coroutine 
def async(string): 
    yield gen.sleep(2) 
    print string 

@gen.coroutine 
def async_call(): 
    return ["one", "two", "three"] 

@coroutine 
def sync(): 
    string_list = yield async_call() 
    for string in string_list: 
     yield async(string) 

loop = IOLoop.current() 
loop.run_sync(sync) 

Выход:

$python test_async.py 
one 
two 
three