異なるスレッドでコルーチンループを実行する

Question

streamSimulationを2スレッド間で4回に分けて呼び出すことにします。

2番目のループを作成し、2番目のスレッドを作成してそのスレッドでループを実行するにはどうすればよいですか？

import asyncio 
import functools 
from concurrent.futures import ThreadPoolExecutor 


async def streamSimulation(p1,p2,p3,p4): 
    print("Stream init") 
    while True: 
     await asyncio.sleep(2) 
     print("Stream Simulation") 
     print("Params: " + p1 + p2 + p3 + p4) 
     doSomething() 

def doSomething(): 
    print("Did something") 

def main(): 
    loop = asyncio.get_event_loop() 
    #Supposed to run in first thread 
    asyncio.ensure_future(streamSimulation("P1","P2","P3","P4")) 
    asyncio.ensure_future(streamSimulation("A1","A2","A3","A4")) 
    #Supposed to run in second thread 
    asyncio.ensure_future(streamSimulation("Q1","Q2","Q3","Q4")) 
    asyncio.ensure_future(streamSimulation("B1","B2","B3","B4")) 
    loop.run_forever() 

main() 

Answer 1

あなたのアイデアは非同期的な方法と競合します。申し訳ありません。一般的に

あなたはCPUバウンドタスクを実行するためのメインスレッドとスレッドプールで単一イベントループを必要としています。

シングルループ理由は、それがループによって実行されるコードは、IO /タイマーイベントのを待つ以外をブロックすることはありません、IOバウンドです。

これは、2つのループがパフォーマンスを向上させないことを意味します。つまり、両方ともカーネルIOサブシステムによってブロックされます。

唯一の例外は、2つの異なるイベントループを同時に作成することです。 asyncioとQt（ただし、この特定のケースの場合はqualmashプロジェクトです）。