coroutine waiter library
This library provide a map associated blocking primitive that waiting for a response produced by another coroutine
Usage
- the map associated interface is through
WaiterMap
fn test_waiter_map() {
let req_map = Arc::new(WaiterMap::<usize, usize>::new());
let req_map_1 = req_map.clone();
let key = 1234;
let waiter = req_map.new_waiter(key);
go!(move || req_map_1.set_rsp(&key, 100).ok());
let result = waiter.wait_rsp(None).unwrap();
assert_eq!(result, 100);
}
- the token associated interface is through
TokenWaiter
, which not need a map
fn test_token_waiter() {
for j in 0..100 {
let result = go!(move || {
let waiter = TokenWaiter::<usize>::new();
let waiter = Pin::new(&waiter);
let id = waiter.id().unwrap();
go!(move || TokenWaiter::set_rsp(id, j + 100));
assert_eq!(waiter.wait_rsp(None).unwrap(), j + 100);
let id = waiter.id().unwrap();
go!(move || TokenWaiter::set_rsp(id, j));
waiter.wait_rsp(std::time::Duration::from_secs(2)).unwrap()
})
.join()
.unwrap();
assert_eq!(result, j);
}
}