Python asyncioタスクの注文

Question

Pythonのasyncioモジュールのイベントループが未処理タスクをどのように管理しているかについて質問があります。これは印刷されます実行

import asyncio 

@asyncio.coroutine 
def a(): 
    for i in range(0, 3): 
     print('a.' + str(i)) 
     yield 


@asyncio.coroutine 
def b(): 
    for i in range(0, 3): 
     print('b.' + str(i)) 
     yield 


@asyncio.coroutine 
def c(): 
    for i in range(0, 3): 
     print('c.' + str(i)) 
     yield 


tasks = [ 
    asyncio.Task(a()), 
    asyncio.Task(b()), 
    asyncio.Task(c()), 
] 

loop = asyncio.get_event_loop() 
loop.run_until_complete(asyncio.wait([t1, t2, t3])) 

：以下のコードを考えてみましょう、それは常に '' そしてその後、 'B' 'C' プリントアウトし

a.0 
b.0 
c.0 
a.1 
b.1 
c.1 
a.2 
b.2 
c.2 

ていることに注意してください。私は、各コルーチンが何回繰り返されても、常にその順序で印刷されることになります。だから、これはイベントループがここでそれが次に実行するタスクを決定するために使用する内部キューを維持していることを私に伝え、Node.jsの背景から来る

b.100 
c.100 
a.100 

ようなものを見ることはないと思います。最初にa()をキューの先頭に置き、b()、次にc()とします。これは、リスト内のタスクの順番がasyncio.wait()に渡されているためです。次に、yieldステートメントを実行するたびに、そのタスクがキューの最後に置かれます。より現実的な例では、非同期httpリクエストを行っている場合、http応答が戻った後にa()をキューの最後に戻すと言います。

私はこれに助言を得ることができますか？

Answer 1

現在、この例にはブロックI/Oコードは含まれていません。

import asyncio 


@asyncio.coroutine 
def coro(tag, delay): 
    for i in range(1, 8): 
     print(tag, i) 
     yield from asyncio.sleep(delay) 


loop = asyncio.get_event_loop() 

print("---- await 0 seconds :-) --- ") 
tasks = [ 
    asyncio.Task(coro("A", 0)), 
    asyncio.Task(coro("B", 0)), 
    asyncio.Task(coro("C", 0)), 
] 

loop.run_until_complete(asyncio.wait(tasks)) 

print("---- simulate some blocking I/O --- ") 
tasks = [ 
    asyncio.Task(coro("A", 0.1)), 
    asyncio.Task(coro("B", 0.3)), 
    asyncio.Task(coro("C", 0.5)), 
] 

loop.run_until_complete(asyncio.wait(tasks)) 

loop.close() 

ご覧のとおり、コルーチンは必要に応じてスケジュールされ、順序通りにスケジュールされていません。