Struct RunControl 

pub struct RunControl { /* private fields */ }

Graceful shutdown control for Pregel execution

Allows external callers to request drain (finish current tasks but don’t start new ones). Checked in PregelLoop::tick() before computing next tasks.

Examples

use juncture_core::pregel::loop_::RunControl;

let run_control = RunControl::new();

// Request drain from another thread
let rc_clone = run_control.clone();
std::thread::spawn(move || {
    // After some condition, request drain
    rc_clone.request_drain();
});

// In the main loop
if run_control.is_drain_requested() {
    // Finish current tasks but don't start new ones
}

Implementations

impl RunControl

pub fn new() -> Self

Create a new run control instance

Examples

use juncture_core::pregel::loop_::RunControl;

let run_control = RunControl::new();
assert!(!run_control.is_drain_requested());

pub fn request_drain(&self)

Request drain (finish current tasks but don’t start new ones)

This is thread-safe and can be called from any thread.

Examples

use juncture_core::pregel::loop_::RunControl;

let run_control = RunControl::new();
run_control.request_drain();
assert!(run_control.is_drain_requested());

pub fn is_drain_requested(&self) -> bool

Check if drain has been requested

Examples

use juncture_core::pregel::loop_::RunControl;

let run_control = RunControl::new();
assert!(!run_control.is_drain_requested());

Trait Implementations

impl Clone for RunControl

fn clone(&self) -> RunControl

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for RunControl

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

Formats the value using the given formatter.

impl Default for RunControl

fn default() -> Self

Returns the “default value” for a type.