Struct ThreadedEngine 

pub struct ThreadedEngine { /* private fields */ }

Thread-safe wrapper around Engine that enables vertical scaling through thread pools

Implementations

impl ThreadedEngine

pub fn new( workflows: Vec<Workflow>, custom_functions: Option<HashMap<String, Box<dyn FunctionHandler + Send + Sync>>>, retry_config: Option<RetryConfig>, thread_count: usize, ) -> Self

Creates a new ThreadedEngine with configurable thread pool size

Arguments

• workflows - The workflows to use for processing messages
• custom_functions - Optional custom function handlers
• retry_config - Optional retry configuration
• thread_count - Number of worker threads to spawn

pub async fn process_message(&self, message: Message) -> Result<Message>

Process a message asynchronously using the thread pool

pub fn process_message_sync(&self, message: Message) -> Result<Message>

Process a message synchronously (blocks until complete)

pub fn shutdown(&self)

Initiates graceful shutdown of the engine

pub fn wait_for_shutdown(self)

Waits for all workers to finish current work and terminate

pub fn shutdown_with_timeout(self, timeout: Duration)

Shutdown with timeout

pub fn is_healthy(&self) -> bool

Health check for worker threads

pub fn thread_count(&self) -> usize

Get the number of worker threads

Trait Implementations

impl Clone for ThreadedEngine

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Drop for ThreadedEngine

fn drop(&mut self)

Executes the destructor for this type.