Struct WorkStealingQueue 

pub struct WorkStealingQueue { /* private fields */ }

Work stealing queue for load balancing

Implementations

impl WorkStealingQueue

pub fn new(steal_threshold: usize) -> Self

Create a new work stealing queue

pub fn push(&self, work: Box<dyn FnOnce(&GpuDevice) -> Result<()> + Send>)

Push work to local queue

pub fn pop(&self) -> Option<Box<dyn FnOnce(&GpuDevice) -> Result<()> + Send>>

Pop work from local queue

pub fn steal(&self) -> Vec<Box<dyn FnOnce(&GpuDevice) -> Result<()> + Send>>

Steal work from this queue (take half if above threshold)

pub fn len(&self) -> usize

Get queue length

pub fn is_empty(&self) -> bool

Check if queue is empty

pub fn should_allow_stealing(&self) -> bool

Check if stealing should be allowed