好的,我可能会让这变得更复杂,但我有一个类:
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
我想为列表中的每个单词启动一个单独的进程,ProcessPoolExecutor
并使用Worker
fromworker_pool
来处理列表中的每个项目。我怎么做??