Окунитесь в `комбу. Потребитель`

  1. Является kombu.Consumer процесс / поток, который на самом деле вызывает __callback__ и выполняет задачу, или это просто родитель, который порождает детей для выполнения задач?
  2. Мне нужно загрузить некоторые веса в графический процессор до того, как задача ставится в очередь, чтобы максимизировать пропускную способность (загрузка, когда запрашиваемая задача слишком медленная). Я планирую сделать это путем создания экземпляров потоков / процессов, которые будут выполнять задачу заранее с весами, загруженными в графический процессор при их создании. Эти потоки / процессы не умрут после выполнения задач. Это будет означать, что мне потребуется контроль над тем, когда такие потоки / процессы порождают, умирают, и как они создаются. Это вообще возможно с комбу и сельдереем?

0 ответов

Другие вопросы по тегам