Struct JobQueue 

pub struct JobQueue { /* private fields */ }

In-memory job queue with concurrency control.

Implementations

impl JobQueue

pub fn new(max_concurrent: usize) -> Self

Creates a new job queue with the specified concurrency limit.

pub fn max_concurrent(&self) -> usize

Returns the max concurrent jobs setting.

pub async fn submit(&self, request: JobRequest) -> JobId

Submits a new job and returns its ID.

pub async fn get(&self, id: &str) -> Option<JobEntry>

Gets the current state of a job.

pub async fn list(&self) -> Vec<JobSummary>

Lists all jobs.

pub async fn cancel(&self, id: &str) -> bool

Attempts to cancel a queued job. Returns true if cancelled.

pub async fn mark_running(&self, id: &str)

Marks a job as running.

pub async fn mark_completed(&self, id: &str, result: JobResult)

Marks a job as completed.

pub async fn mark_failed(&self, id: &str, error: String)

Marks a job as failed.

pub fn semaphore(&self) -> Arc<Semaphore>

Returns a clone of the concurrency semaphore for job execution.