非同期サブルーチンの作成中にPython tornadoのrun_syncを使用するには？

Question

私は非同期メソッドを起動する竜巻IOLoopのrun_syncでメソッドを実行したいと思います。

はここにアイデアだ：だから

@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で非同期的に実行する2つの関数がある場合、各関数のコードは同時に実行されますが、関数のワークフローは依然として同期しています。

yieldキーワードなしでasyncメソッドを実行すると、特に、機能停止後にIOLoopを停止するrun_syncを使用すると、呼び出し元関数の前に終了するようになります。 asyncが実行中でもIOLoopが停止していると、未定義の動作が発生する可能性があります。

私はsyncの機能のワークフローを同期的に実行されることを示すためにあなたのコードを編集した：

@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