agent_rt 0.2.0

agent scheduling
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

use crate::{WakerCallBack, WakerWaitPool};
use std::collections::HashMap;
use std::sync::Mutex;

#[derive(Default)]
pub struct DefaultWakerPool {
    map: Mutex<HashMap<String, WakerCallBack>>,
}

impl WakerWaitPool for DefaultWakerPool {
    fn push(&self, code: String, waker: WakerCallBack) {
        let mut map = match self.map.lock() {
            Ok(o) => o,
            Err(e) => {
                wd_log::log_error_ln!("DefaultWakerPool,push error:{}", e);
                return;
            }
        };
        map.insert(code, waker);
    }

    fn remove(&self, code: &str) -> Option<WakerCallBack> {
        let mut map = match self.map.lock() {
            Ok(o) => o,
            Err(e) => {
                wd_log::log_error_ln!("DefaultWakerPool,remove error:{}", e);
                return None;
            }
        };
        map.remove(code)
    }
}