Struct DeadlockDetector 

pub struct DeadlockDetector { /* private fields */ }

Deadlock detection system

Implementations

impl DeadlockDetector

pub fn new() -> Self

Create a new deadlock detector

pub fn add_blocked_request(&mut self, request: BlockedRequest)

Add a blocked request to track

Examples

use ruchy::runtime::observatory::add_blocked_request;

let result = add_blocked_request(());
assert_eq!(result, Ok(()));

pub fn remove_blocked_request(&mut self, requester: ActorId, target: ActorId)

Remove a blocked request (when resolved)

Examples

use ruchy::runtime::observatory::remove_blocked_request;

let result = remove_blocked_request(());
assert_eq!(result, Ok(()));

pub fn detect_cycles(&mut self) -> Result<Vec<DeadlockCycle>>

Detect cycles in the dependency graph (potential deadlocks)

Examples

use ruchy::runtime::observatory::detect_cycles;

let result = detect_cycles(());
assert_eq!(result, Ok(()));

Trait Implementations

impl Debug for DeadlockDetector

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

Formats the value using the given formatter.

impl Default for DeadlockDetector

fn default() -> Self

Returns the “default value” for a type.