Struct AsyncComputeQueue 

pub struct AsyncComputeQueue { /* private fields */ }

Queue that manages overlapping compute and render work.

Submit compute jobs which are dispatched in order. Fences are inserted after each job so that subsequent render work can wait for completion.

Implementations

impl AsyncComputeQueue

pub fn new(max_in_flight: usize) -> Self

Create a new async queue.

pub fn submit( &mut self, program_key: u64, dimension: DispatchDimension, uniforms: Vec<UniformValue>, barrier: MemoryBarrierFlags, ) -> u64

Submit a compute job. Returns a job ID for tracking.

pub fn flush(&mut self, gl: &Context, cache: &PipelineCache)

Flush: dispatch all pending jobs up to max_in_flight.

pub fn poll(&mut self, gl: &Context)

Poll all in-flight jobs and mark completed ones.

pub fn drain_completed(&mut self) -> Vec<u64>

Remove and return all completed job IDs.

pub fn is_complete(&self, job_id: u64) -> bool

Check if a specific job is complete.

pub fn wait_for(&mut self, gl: &Context, job_id: u64, timeout: Duration) -> bool

Wait for a specific job to complete.

pub fn pending_count(&self) -> usize

Number of pending (not yet dispatched) jobs.

pub fn in_flight_count(&self) -> usize

Number of in-flight (dispatched but not completed) jobs.

pub fn total_count(&self) -> usize

Total number of jobs in the queue.

pub fn destroy(self, gl: &Context)

Destroy the queue, cleaning up fences.