2 个版本

0.1.3 2021 年 3 月 14 日
0.1.2 2021 年 3 月 14 日

#909并发

MIT/Apache

14KB

线程间的一次性值交换。消费者线程可能等待生产者线程,生产和消费者都是单次使用

只是一个封装了 std::mpsc 通道,并具有使其无法重复使用的 API 的包装器

示例

let (send, recv) = promissory::promissory();
std::thread::spawn(move || send.fulfill(42u32));
assert_eq!(42, recv.await_value()?;

lib.rs:

线程间的一次性值交换。消费者线程可能等待生产者线程,生产和消费者都是单次使用

只是一个封装了 std::mpsc 通道,并具有使其无法重复使用的 API 的包装器

示例

use promissory::{promissory, Awaiter};
let (send, recv) = promissory::promissory();
std::thread::spawn(move || send.fulfill(42u32));
assert_eq!(42, recv.await_value().expect("this thread cannot die"));

无运行时依赖