わかりました、おそらくこれを必要以上に複雑にしていますが、クラスがあります:
class Worker:
def __init__(self):
pass
async def do_something(self,word: str):
print(word)
私は別のクラスを持っています:
class WorkerManager:
def __init__(self):
self.worker_pool = [Worker() for _ in range(10)]
WorkerManager
asyncio で実行したいのですが、リスト内の単語ごとWorkerManager
に個別のプロセスを開始し、 fromを使用してリスト内の各項目を処理したいと考えています。それ、どうやったら出来るの??ProcessPoolExecutor
Worker
worker_pool