pub async fn get_state(&self) -> (usize, bool) {
let (tx, rx) = tokio::sync::oneshot::channel();
let ev = Event::GetState(tx);
loop {
let ev = match self.ev_q.put(ev).await {
Ok(_) => break,
Err(ev) => ev
};
tokio::time::sleep(Duration::from_millis(20)).await;
}
rx.await.unwrap()
}
不断调用一个函数 self.ev_q.put
, 该函数会获取参数 ev
的所有权. 如果成功则退出循环, 失败则函数会返回参数的所有权; 然后在下一次循环中再次调用. 但是发现 Rust 的 borrow checker 好像无法识别出来这个参数的所有权是始终存在的.
如果要实现的话只能写成这样:
pub async fn get_state(&self) -> (usize, bool) {
let (tx, rx) = tokio::sync::oneshot::channel();
let mut ev = Some(Event::GetState(tx));
loop {
let inner = match self.ev_q.put(ev.take().unwrap()).await {
Ok(_) => break,
Err(ev) => ev
};
ev = Some(inner);
tokio::time::sleep(Duration::from_millis(20)).await;
}
rx.await.unwrap()
}
这是一个专为移动设备优化的页面(即为了让你能够在 Google 搜索结果里秒开这个页面),如果你希望参与 V2EX 社区的讨论,你可以继续到 V2EX 上打开本讨论主题的完整版本。
V2EX 是创意工作者们的社区,是一个分享自己正在做的有趣事物、交流想法,可以遇见新朋友甚至新机会的地方。
V2EX is a community of developers, designers and creative people.