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

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

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);
}

为什么选择 Flume?

• 功能丰富: Unbounded, bounded 和 rendezvous 队列
• 快速: 通常比 std::sync::mpsc 更快，某些情况比 crossbeam-channel 更快
• 安全: 代码库中没有使用任何的 unsafe ！
• 灵活: Sender 和 Receiver 同时支持 Send + Sync + Clone
• 熟悉: 几乎和 std::sync::mpsc的用法一致
• 更多功能: 比如 MPMC 支持和发送 timeouts/deadlines
• 简单: 足够小的依赖, 足够小的代码, 足够少的编译时间
• 异步: async支持
• 人体工程学: 强大的类似select的接口

uwu-tray 颜文字跨平台托盘应用程序

task-stream 一个能运行在no_std的全局异步任务spawner

fn test_sync_fun() {
fn sync_task() {
println!("sync_task.");
    }
    task_stream::spawn(async {
        sync_task();
    });
}
fn test_async_fun() {
    async fn async_task() {
println!("async_task.");
    }
    task_stream::spawn(async_task());
}
fn test_capture_var() {
let a: usize = 1;
    task_stream::spawn(async move {
println!("catch a: {}.", a);
    });
}
fn test_sleep() {
    task_stream::spawn(async move {
let mut now: u64 = 0;
loop {
println!("now: {}.", now);
            task_stream::sleep(Duration::from_millis(1000)).await;
            now += 1000;
        }
    });
}

permit 一个用于取消操作的结构体

使用场景

• 优雅的关闭服务
• 取消耗时太长的操作
• 在撤销授权时停止运行中的操作

let top_permit = permit::Permit::new();
// Start some worker threads.
for _ in 0..5 {
let permit = top_permit.new_sub();
    std::thread::spawn(move || {
while !permit.is_revoked() {
// ...
        }
    });
}
wait_for_shutdown_signal();
// Revoke all thread permits.
top_permit.revoke();
// Give the threads time to finish
// and drop their permits.
let _ = top_permit.try_wait_for(
    core::time::Duration::from_secs(3));

功能齐全的FM合成器运行在浏览器上!

pico-args 一个非常简单的命令行参数解析器

• clap - 最受欢迎同时功能最全的
• gumdrop - 一个简单的使用过程宏的解析器
• structopt - 上面两个的缝合体
• argh - 类似于 gumdrop

This Week in Rust 383

• Rust.cc 论坛: 支持 rss
• 微信公众号：Rust 语言中文社区