1 个不稳定版本
0.1.0 | 2023年7月13日 |
---|
#1908 in 异步
6KB
86 行
drop-awaiter
允许您异步等待某事物被释放的库。
文档
示例
struct Task {
id: &'static str,
dn: DropNotifier,
}
async fn foo() {
let (n, awaiter) = crate::new();
let first_task = Task {
id: "first",
dn: n.clone(),
};
std::thread::spawn(move || {
std::thread::sleep(Duration::from_secs(5));
println!("Completed task: {}", first_task.id);
drop(first_task.dn);
});
let second_task = Task {
id: "second",
dn: n,
};
tokio::spawn(async move {
tokio::time::sleep(Duration::from_secs(1)).await;
println!("Completed task: {}", second_task.id);
drop(second_task.dn);
});
// Simply await for completion of tasks (both sync and async) without
// any additional collections to coordinate and track statuses of tasks
awaiter.await;
}
依赖项
~1MB
~15K SLoC