класс ActiveJob::QueueAdapters::AsyncAdapter

Родитель:: ActiveJob::QueueAdapters::AbstractAdapter

Адаптер Active Job Async

Адаптер Async выполняет задачи с потоковым пулом внутри процесса.

Это адаптер очереди по умолчанию. Он хорошо подходит для разработки/тестирования, поскольку не требует внешней инфраструктуры, но он плохо подходит для производства, так как отложенные задачи отбрасываются при перезапуске.

Для использования этого адаптера, установите адаптер очереди на :async:

config.active_job.queue_adapter = :async

Для настройки пула потоков адаптера, создайте адаптер и передайте собственные настройки:

config.active_job.queue_adapter = ActiveJob::QueueAdapters::AsyncAdapter.new \
  min_threads: 1,
  max_threads: 2 * Concurrent.processor_count,
  idletime: 600.seconds

Адаптер использует потоковый пул Concurrent Ruby для планирования и выполнения задач. Поскольку задачи используют один общий пул потоков, длительные задачи будут блокировать кратковременные задачи. Хорошо подходит для разработки/тестирования, плохо для производства.

Публичные методы класса

new(**executor_options) Показать исходный код

# File activejob/lib/active_job/queue_adapters/async_adapter.rb, line 35
def initialize(**executor_options)
  @scheduler = Scheduler.new(**executor_options)
end

См. Concurrent::ThreadPoolExecutor для параметров исполнителя.