2 个版本
0.1.3 | 2021 年 3 月 14 日 |
---|---|
0.1.2 | 2021 年 3 月 14 日 |
#909 在 并发 中
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"));