libpetri-runtime 1.7.0

Bitmap executor runtime for libpetri Coloured Time Petri Net engine
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36

use std::sync::Arc;

use libpetri_core::token::ErasedToken;

/// An external event to inject into the executor.
#[derive(Debug, Clone)]
pub struct ExternalEvent {
    pub place_name: Arc<str>,
    pub token: ErasedToken,
}

/// Signal sent to a running executor via the control channel.
///
/// Merges external events and lifecycle commands into a single enum,
/// avoiding separate channels or atomic flags. The executor's async loop
/// pattern-matches on these variants with O(1) overhead per iteration.
///
/// # Lifecycle signals
///
/// - [`Drain`](Self::Drain) — graceful shutdown per \[ENV-011\]: reject new events,
///   process already-queued events, complete in-flight actions, terminate at quiescence.
/// - [`Close`](Self::Close) — immediate shutdown per \[ENV-013\]: discard queued events,
///   complete in-flight actions, terminate.
///
/// Use [`ExecutorHandle`](crate::executor_handle::ExecutorHandle) for RAII-managed
/// lifecycle with automatic drain on drop.
#[cfg(feature = "tokio")]
#[derive(Debug)]
pub enum ExecutorSignal {
    /// External event injection (existing behavior).
    Event(ExternalEvent),
    /// Graceful drain: reject new events, process queued, terminate at quiescence.
    Drain,
    /// Immediate close: discard queued events, complete in-flight, terminate.
    Close,
}