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 ```rust fn testwaitermap() { let reqmap = Arc::new(WaiterMap::::new()); let reqmap1 = reqmap.clone();

  let key = 1234;

  // one coroutine wait data send from another coroutine // prepare the waiter first let waiter = reqmap.newwaiter(key);

  // trigger the rsp in another coroutine go!(move || reqmap1.set_rsp(&key, 100).ok());

  // this will block until the rsp was set let result = waiter.waitrsp(None).unwrap(); asserteq!(result, 100); } ```

• the token associated interface is through TokenWaiter, which not need a map ```rust fn testtokenwaiter() { for j in 0..100 { let result = go!(move || { let waiter = TokenWaiter::::new(); let waiter = Pin::new(&waiter); let id = waiter.id().unwrap(); // trigger the rsp in another coroutine go!(move || TokenWaiter::setrsp(id, j + 100)); // this will block until the rsp was set asserteq!(waiter.waitrsp(None).unwrap(), j + 100); // after wait we can get the id again let id = waiter.id().unwrap(); go!(move || TokenWaiter::setrsp(id, j)); waiter.waitrsp(std::time::Duration::fromsecs(2)).unwrap() }) .join() .unwrap();

  assert_eq!(result, j);
  

  } } ```