0

好的,我可能会让这变得更复杂,但我有一个类:

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并使用Workerfromworker_pool来处理列表中的每个项目。我怎么做??

4

0 回答 0