Struct CpuQueue 

pub struct CpuQueue { /* private fields */ }

CPU command queue using rayon for parallel execution.

Operations are batched and submitted to rayon’s thread pool. The queue itself is not thread-safe - use one per thread.

Implementations

impl CpuQueue

pub fn new() -> Self

Create a new CPU queue.

Trait Implementations

impl Debug for CpuQueue

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

Formats the value using the given formatter.

impl Default for CpuQueue

fn default() -> Self

Returns the “default value” for a type.

impl HardwareQueue for CpuQueue

type Signal = CpuTimelineSignal

The timeline signal type used by this queue.

fn wait(&mut self, signal: &Self::Signal, value: u64) -> &mut Self

Wait for a signal to reach a value before executing subsequent operations.

fn signal(&mut self, signal: &Self::Signal, value: u64) -> &mut Self

Signal a value after all previous operations complete.

fn exec( &mut self, program: Arc<dyn DeviceProgram>, buffers: &[&Buffer], params: &ExecParams, ) -> &mut Self

Execute a compiled program with the given buffers and parameters.

fn copy(&mut self, dst: &Buffer, src: &Buffer) -> &mut Self

Copy data between buffers.

fn memory_barrier(&mut self) -> &mut Self

Insert a memory barrier.

fn submit(&mut self) -> Result<()>

Submit all batched operations to the hardware.

fn device(&self) -> &DeviceSpec

Get the device this queue belongs to.