class

Fluorite::BatchQueue

Inherits Reference < Object

Constructors

new(concurrency : Int32 = 1)
Source

Instance methods

add(input : String, output : String, &) : BatchJob
Source
add(job : BatchJob) : self
Source
completed_count
Source
concurrency
Source
concurrency=(concurrency : Int32)
Source
failed_count
Source
jobs
Source
on_job_complete
Source
on_job_fail
Source
on_job_progress
Source
on_job_start
Source
run

Runs all jobs sequentially or up to concurrency limit

Source
total_count
Source