Struct StealingQueue 

pub struct StealingQueue<TTask: Prioritized<Kind = Priority>> {
    Share: Arc<Share<TTask>>,
}

A generic, priority-aware, work-stealing queue.

This is the public-facing entry point for submitting tasks. It is generic over any task type TTask that implements the Prioritized trait.

Fields

Share: Arc<Share<TTask>>

A shared, thread-safe pointer to the queue’s shared components.

Implementations

impl<TTask: Prioritized<Kind = Priority>> StealingQueue<TTask>

pub fn Create(Count: usize) -> (Self, Vec<Context<TTask>>)

Creates a complete work-stealing queue system.

This function initializes all the necessary queues, both shared and thread-local, for a given number of workers.

Returns

A tuple containing:

1. The public-facing StealingQueue for submitting new tasks.
2. A Vec of Context objects, one for each worker thread to own.

pub fn Submit(&self, Task: TTask)

Submits a new task to the appropriate global queue based on its priority. This method is thread-safe and can be called from any context.