#async #non-blocking #future

drop-awaiter

允许您异步等待某事物被释放的库

1 个不稳定版本

0.1.0 2023年7月13日

#1908 in 异步

MIT 许可证

6KB
86

drop-awaiter

允许您异步等待某事物被释放的库。

文档

Rustdoc

示例

    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