pythonでasync/awaitを使う方法+ +

Question

私は非同期プログラミングの例をpythonで説明しようとしていましたが、失敗しました。 ここに私のコードです。

Foo 
asyncFoo 

を10秒の待ち時間でasyncFooが表示されていた前に：

import asyncio 
import time 

async def asyncfoo(t): 
    time.sleep(t) 
    print("asyncFoo") 


loop = asyncio.get_event_loop() 
loop.run_until_complete(asyncfoo(10)) # I think Here is the problem 
print("Foo") 
loop.close() 

私の期待は、私が見るであろうということです。

しかし、代わりに私は10歳で何も得ていないし、両方とも表示しています。

私は何が間違っているのですか？どのように説明できますか？

Answer 1

run_until_completeは、asyncfooまでブロックされます。代わりに、2つのコルーチンがループ内で実行されている必要があります。 asyncio.gatherを使用すると、run_until_completeで複数のコルーチンを簡単に開始できます。ここで

は一例です：

import asyncio 


async def async_foo(): 
    print("asyncFoo1") 
    await asyncio.sleep(3) 
    print("asyncFoo2") 


async def async_bar(): 
    print("asyncBar1") 
    await asyncio.sleep(1) 
    print("asyncBar2") 


loop = asyncio.get_event_loop() 
loop.run_until_complete(asyncio.gather(async_foo(), async_bar())) 
loop.close() 

Answer 2

run_until_completeがブロックしています。だから、たとえそれが10秒で起こっても、それはそれを待つでしょう。完了後、もう1枚印刷されます。

「Foo」を以前に印刷したい場合は、loop.run_until_complete(asyncfoo(10))をスレッドまたはサブプロセスで起動する必要があります。

Answer 3

コードフローとは無関係にコルーチンをTaskとして実行するコンテキストでは、期待通りの効果が得られます。 coroutinesを複数並べて実行している場合は、イベントループによってコード実行がawaitからawaitに変更されます。

例のコンテキスト内では、タスクオブジェクトにコルーチンをラップすることで、予想される動作を達成できます。タスクオブジェクトは、コードブロック内の残りのコードを保持せずにバックグラウンドで続行しますが呼び出されます。

たとえば、

import asyncio 

async def asyncfoo(t): 
    await asyncio.sleep(t) 
    print("asyncFoo") 

async def my_app(t): 
    my_task = asyncio.ensure_future(asyncfoo(t)) 
    print("Foo") 
    await asyncio.wait([my_task]) 

loop = asyncio.get_event_loop() 
loop.run_until_complete(my_app(10)) 
loop.close() 

あなたの代わりにtimeモジュールのasyncio.sleep()を使用する必要があります注意してください。