модуль ActiveJob::QueueAdapters

Адаптеры Active Job

Active Job имеет адаптеры для следующих backends очередей:

• Backburner

• Delayed Job

• Qu

• Que

• queue_classic

• Resque

• Sidekiq

• Sneakers

• Sucker Punch

• Асинхронная работа Active Job

• Встроенная работа Active Job

Особенности бэкэндов

|                   | Async | Queues | Delayed    | Priorities | Timeout | Retries |
|-------------------|-------|--------|------------|------------|---------|---------|
| Backburner        | Yes   | Yes    | Yes        | Yes        | Job     | Global  |
| Delayed Job       | Yes   | Yes    | Yes        | Job        | Global  | Global  |
| Qu                | Yes   | Yes    | No         | No         | No      | Global  |
| Que               | Yes   | Yes    | Yes        | Job        | No      | Job     |
| queue_classic     | Yes   | Yes    | Yes*       | No         | No      | No      |
| Resque            | Yes   | Yes    | Yes (Gem)  | Queue      | Global  | Yes     |
| Sidekiq           | Yes   | Yes    | Yes        | Queue      | No      | Job     |
| Sneakers          | Yes   | Yes    | No         | Queue      | Queue   | No      |
| Sucker Punch      | Yes   | Yes    | Yes        | No         | No      | No      |
| Active Job Async  | Yes   | Yes    | Yes        | No         | No      | No      |
| Active Job Inline | No    | Yes    | N/A        | N/A        | N/A     | N/A     |

Асинхронно

Да: Адаптер очереди может выполнять задачу в неблокирующем режиме. Он выполняется в отдельном или виртуализированном процессе, или в другом потоке.

Нет: Задача выполняется в том же процессе.

Очереди

Да: Задачи могут указывать, в какой очереди они будут выполняться, с помощью queue_as или метода set.

Отложенно

Да: Адаптер выполнит задачу в будущем с помощью perform_later.

(Gem): Для использования perform_later с этим адаптером требуется дополнительный gem.

Нет: Адаптер выполнит задачи в ближайшее время и не может использовать perform_later.

Не применимо: Адаптер не поддерживает очереди.

ПРИМЕЧАНИЕ: queue_classic поддерживает планирование задач с версии 3.1. Для более старых версий можно использовать gem queue_classic-later.

Приоритеты

Порядок обработки задач может быть настроен по-разному в зависимости от адаптера.

Задача: Любой класс, наследующий от адаптера, может установить приоритет объекта задачи относительно других задач.

Очередь: Адаптер может установить приоритет для очередей задач; при установке очереди с помощью Active Job этот приоритет будет учтён.

Да: Позволяет устанавливать приоритет объекта задачи, на уровне очереди или в качестве опции конфигурации по умолчанию.

Нет: Не позволяет настраивать приоритет задач.

Не применимо: Адаптер не поддерживает очереди и, следовательно, сортировку.

Таймаут

Время, когда задача остановится после выделенного времени.

Задача: Таймаут может быть установлен для каждого экземпляра класса задачи.

Очередь: Таймаут устанавливается для всех задач в очереди.

Глобально: Адаптер настроен так, что у всех задач есть максимальное время выполнения.

Не применимо: Этот адаптер не работает в отдельном процессе, поэтому таймаут не поддерживается.

Повторные попытки

Задача: Количество повторов может быть установлено для каждого экземпляра класса задачи.

Да: Количество повторных попыток можно настроить глобально, для каждого экземпляра или в очереди. Этот адаптер также может представлять неудачные экземпляры класса задачи, которые можно перезапустить.

Глобально: Адаптер имеет глобальное количество повторных попыток.

Не применимо: Адаптер не работает в отдельном процессе и, следовательно, не поддерживает повторные попытки.

Асинхронные и встроенные адаптеры очереди

Active Job имеет два встроенных адаптера очереди, предназначенные для разработки и тестирования: :async и :inline.