1 2 3 4 5 6 7 8 9 10
use std::sync::Arc; use rmcp::task_manager::OperationProcessor; use tokio::sync::Mutex; pub type TaskProcessor = Arc<Mutex<OperationProcessor>>; pub fn new_task_processor() -> TaskProcessor { Arc::new(Mutex::new(OperationProcessor::new())) }