赞
踩
简单示例:
- use std::thread;
-
- fn main() {
- println!("Hello, world!");
-
- let (tx, rx) = flume::unbounded();
-
- thread::spawn(move || {
- (0..10).for_each(|i| {
- tx.send(i).unwrap();
- })
- });
-
- let received: u32 = rx.iter().sum();
-
- assert_eq!((0..10).sum::<u32>(), received);
- }
-
功能丰富: Unbounded, bounded 和 rendezvous 队列
快速: 通常比 std::sync::mpsc
更快,某些情况比 crossbeam-channel
更快
安全: 代码库中没有使用任何的 unsafe
!
灵活
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。