class ActiveJob::QueueAdapters::AsyncAdapter::Scheduler

def shutdown(wait: true)

def shutdown(wait: true)
  @async_executor.shutdown
  @async_executor.wait_for_termination if wait
end