python: как заставить потоки ждать определенного ответа?

If a threads waits for a specific task completion, i.e it shouldn't pick any completed task except that one it put, you can use locks to wait for the task:

  def run(self):
    # get a task, do somethings, put a new task
    newTask.waitFor()
    ...


задача класса: ... def waitFor(self): self._lock.acquire()

защита завершена (я): self._lock.release ()

def failedToComplete(self, err): self._error = err self._lock.release()

Это поможет избежать time.sleep()-s при мониторинге очереди ответов. Здесь следует рассмотреть обработку ошибок завершения задачи. Но это нестандартный подход. Это какой-то определенный алгоритм, где поток, который ставит новую задачу, должен ждать ее? Тем не менее, вы можете реализовать эту логику в классе Task, а не в потоке, который ее обрабатывает. И почему поток выбирает задачу из очереди назначения и помещает новую задачу обратно в очередь назначения? Если у вас есть n шагов обработки, вы можете использовать для этого n очередей. Группа потоков обслуживает первую очередь, получает задачу, обрабатывает ее, помещает результат (новую задачу) в следующую очередь. Группа конечных потоков-обработчиков ответов получает ответ и отправляет его обратно клиенту. Задачи инкапсулируют сведения о себе, потоки не отличают одну задачу от другой. И нет необходимости ждать конкретной задачи.