当前位置:   article > 正文

【Rust 日报】2021-03-25 linux-next的rust-next分支被合并了!

flume::unbounded

linux-next的rust-next分支被合并了

Flume 一个安全快速的多生产者多消费者通道实现

简单示例:

  1. use std::thread;
  2. fn main() {
  3. println!("Hello, world!");
  4. let (tx, rx) = flume::unbounded();
  5. thread::spawn(move || {
  6. (0..10).for_each(|i| {
  7. tx.send(i).unwrap();
  8. })
  9. });
  10. let received: u32 = rx.iter().sum();
  11. assert_eq!((0..10).sum::<u32>(), received);
  12. }
为什么选择 Flume?
  • 功能丰富: Unbounded, bounded 和 rendezvous 队列

  • 快速: 通常比 std::sync::mpsc 更快,某些情况比 crossbeam-channel 更快

  • 安全: 代码库中没有使用任何的 unsafe !

  • 灵活

声明:本文内容由网友自发贡献,转载请注明出处:【wpsshop博客】
推荐阅读
相关标签
  

闽ICP备14008679号