Struct ManagedThreadService 

pub struct ManagedThreadService { /* private fields */ }

Managed adapter for one cooperatively cancellable thread.

Implementations

impl ManagedThreadService

pub fn new<F>(descriptor: ServiceDescriptor, factory: F) -> Self

where F: Fn(Arc<AtomicBool>) -> Result<JoinHandle<Result<(), String>>, String> + Send + Sync + 'static,

Creates a managed thread from a restartable factory.

pub fn with_health_probe<H>(self, health_probe: H) -> Self

where H: Fn() -> ServiceHealth + Send + Sync + 'static,

Adds a live health probe evaluated while the thread is running.

Trait Implementations

impl ManagedService for ManagedThreadService

fn descriptor(&self) -> &ServiceDescriptor

Returns immutable identity, dependencies, resource, and policy.

fn start(&self) -> SupervisorResult<()>

Starts the service and its bounded resources.

fn stop(&self, timeout: Duration) -> SupervisorResult<()>

Requests cooperative shutdown inside timeout.

fn health(&self) -> ServiceHealth

Returns current service health.

fn runtime_state(&self) -> ServiceRuntimeState

Returns the concrete service execution state.