Struct LockFreeBatchProcessor 

pub struct LockFreeBatchProcessor { /* private fields */ }

Lock-free batch processor for parallel vector operations (ADR-001)

Distributes work across multiple workers without contention.

Implementations

impl LockFreeBatchProcessor

pub fn new(capacity: usize) -> Self

Create a new batch processor with given capacity

pub fn submit(&self, item: BatchItem) -> Result<(), BatchItem>

Submit a batch item for processing

pub fn try_get_work(&self) -> Option<BatchItem>

Try to get a work item (for workers)

pub fn submit_result(&self, result: BatchResult)

Submit a result (from workers)

pub fn collect_results(&self) -> Vec<BatchResult>

Collect all available results

pub fn pending(&self) -> usize

Get pending count

pub fn completed(&self) -> usize

Get completed count

pub fn is_done(&self) -> bool

Check if all work is done