Struct SharedState 

pub struct SharedState {
    pub shutdown: Arc<AtomicBool>,
    pub task_counter: Arc<AtomicU64>,
    pub global_queue: Arc<Mutex<VecDeque<TaskId>>>,
    pub results: Arc<Mutex<HashMap<TaskId, RtObject>>>,
}

Thread-safe shared state for the scheduler.

In a real multi-threaded implementation, this would be accessed by multiple worker threads.

Fields

shutdown: Arc<AtomicBool>

Whether the scheduler should stop.

task_counter: Arc<AtomicU64>

Global task counter.

global_queue: Arc<Mutex<VecDeque<TaskId>>>

Shared global queue.

results: Arc<Mutex<HashMap<TaskId, RtObject>>>

Shared task results.

Implementations

impl SharedState

pub fn new() -> Self

Create new shared state.

pub fn request_shutdown(&self)

Request shutdown.

pub fn should_shutdown(&self) -> bool

Check if shutdown was requested.

pub fn next_task_id(&self) -> TaskId

Generate a new task ID.

pub fn push_task(&self, task_id: TaskId)

Push a task to the global queue.

pub fn pop_task(&self) -> Option<TaskId>

Pop a task from the global queue.

pub fn store_result(&self, task_id: TaskId, result: RtObject)

Store a task result.

pub fn get_result(&self, task_id: TaskId) -> Option<RtObject>

Get a task result.

Trait Implementations

impl Debug for SharedState

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

Formats the value using the given formatter.

impl Default for SharedState

fn default() -> Self

Returns the “default value” for a type.