带有asyncio的Python工作池[关闭]

Question

关闭。这个问题需要更多focused。它当前不接受答案。

---

是否要改善此问题？更新问题，使其仅按editing this post专注于一个问题。

[<3小时前关闭。

如何制作三个异步线程来处理数据直到结束？

有asyncio Queue的解决方案，但在运行之前，队列应充满任务。单个任务完成后，我需要获取新数据进行处理。

我举了个例子来描述我想做的事情：

这里是javascript中的示例。如何在python中制作这个？

function getRandomInt(max) {
  return Math.floor(Math.random() * Math.floor(max));
}

function job(iteration) {
  console.log(iteration + ' started')
  setTimeout(function () {
    completeJob(iteration)
  }, getRandomInt(1000))
}

function completeJob(iteration) {
  console.log(iteration + ' ended')
  nextJob()
}

function nextJob() {
  if (iteration < 10) {
    job(iteration++)
  }
}

function runPool(pool) {
  iteration = 0

  for (var p = 0; p < pool; p++) {
    nextJob(iteration)
  }
}

runPool(3)

Answer 1

您可以尝试使用multiprocessing。

https://docs.python.org/3.7/library/multiprocessing.html