Struct ConcurrentConversionManager 

pub struct ConcurrentConversionManager { /* private fields */ }

Thread-safe concurrent conversion manager

Implementations

impl ConcurrentConversionManager

pub fn new( max_concurrent_operations: usize, max_cached_models: usize, config: ConversionConfig, ) -> Self

Create new concurrent conversion manager with specified concurrency limits

pub async fn convert_with_concurrency_control( &self, request: ConversionRequest, ) -> Result<ConversionResult>

Process conversion request with thread-safe concurrency control and metrics tracking

pub async fn get_metrics(&self) -> ConcurrentConversionMetrics

Get current conversion metrics snapshot

pub async fn get_operation_state(&self) -> OperationState

Get current operation state snapshot with active operations

pub async fn update_config(&self, new_config: ConversionConfig) -> Result<()>

Update configuration with thread-safe write lock

pub async fn get_config(&self) -> ConversionConfig

Get current configuration snapshot with thread-safe read lock

pub async fn health_check(&self) -> HashMap<String, String>

Perform health check and return status metrics for monitoring

pub async fn shutdown(&self) -> Result<()>

Gracefully shutdown manager waiting for active operations to complete