Struct AsyncExecutor 

pub struct AsyncExecutor { /* private fields */ }

Async execution engine with enhanced batching and priority support

Implementations

impl AsyncExecutor

pub fn new(device: Device) -> Self

Create a new async executor for a device

pub fn with_batch_size(device: Device, batch_size: usize) -> Self

Create a new async executor with specified batch size

pub fn submit(&self, kernel: Box<dyn AsyncKernel>) -> AsyncOperation

Submit an async operation

pub fn submit_with_priority( &self, kernel: Box<dyn AsyncKernel>, priority: Priority, ) -> AsyncOperation

Submit an async operation with specified priority

pub async fn process_queue(&self) -> Result<()>

Process pending operations with advanced batching and priority handling

pub fn queue_length(&self) -> usize

Get total queue length (both normal and high priority)

pub fn queue_length_by_priority(&self, high_priority: bool) -> usize

Get queue length by priority

pub fn clear_queue(&self)

Clear all pending operations

pub fn get_stats(&self) -> ExecutorStats

Get execution statistics

pub fn reset_stats(&self)

Reset execution statistics

pub fn device(&self) -> Device

Get device this executor manages

pub fn is_processing(&self) -> bool

Check if executor is currently processing