class

ActiveJob::AsyncAdapter

Inherits ActiveJob::Adapter < Reference < Object

Constructors

new(pool_size : Int32 = 8, queue_size : Int32 = 1024)
Source

Instance methods

enqueue(record : EnqueuedJob) : Nil
Source
performed
shutdown
Source
wait_empty

Block until every enqueued job has been performed (bench seam). Fibers are cooperative: yielding lets workers drain the queue.

Source