Struct AsyncComputeQueue 

pub struct AsyncComputeQueue {
    pub submission_count: u64,
    pub completed_count: u64,
    /* private fields */
}

Lightweight async compute task queue.

In the CPU-stub backend, tasks complete synchronously; the API is designed to be drop-in replaceable with an actual GPU async queue once a WGPU device is available.

Fields

submission_count: u64

Monotonically increasing submission counter.

completed_count: u64

Number of tasks that have been polled and returned a result.

Implementations

impl AsyncComputeQueue

pub fn new() -> Self

Create a new, empty async compute queue.

pub fn submit(&mut self, task_id: u64, data: Vec<u8>)

Submit a compute task.

• task_id – Caller-defined identifier for this task.
• data – Input payload (or pre-computed output on CPU path).

If a task with the same task_id already exists it is replaced.

pub fn poll(&mut self, task_id: u64) -> Option<Vec<u8>>

Poll for the result of a previously submitted task.

Returns Some(result) if the task has completed, consuming the result from the queue (subsequent polls for the same task_id return None). Returns None if the task is still pending/running or has already been consumed.

pub fn state(&self, task_id: u64) -> Option<&TaskState>

Query the current state of a task without consuming the result.

Returns None if no task with that task_id exists (either never submitted or already consumed by Self::poll).

pub fn cancel(&mut self, task_id: u64) -> bool

Cancel a pending or running task.

Returns true if the task was found and removed.

pub fn active_count(&self) -> usize

Number of tasks currently tracked (pending, running, or complete).

pub fn is_empty(&self) -> bool

true if no tasks are currently tracked.

pub fn fail_task(&mut self, task_id: u64, error: String)

Mark a task as failed with an error message (useful for testing error paths).

pub fn is_failed(&self, task_id: u64) -> bool

Returns true if the task with task_id has failed.

Trait Implementations

impl Debug for AsyncComputeQueue

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for AsyncComputeQueue

fn default() -> AsyncComputeQueue

Returns the “default value” for a type.