futures-concurrency

高效的、可移植的异步Rust结构化并发操作。它与任何运行时都兼容，不删除生命周期，始终处理取消，并始终将输出返回给调用者。

futures-concurrency 为futures和streams两组提供并发操作。对于有界和无界futures和streams集合都适用。在这两种情况下，性能应与，如果不在常规执行器实现之上，则应相当。

示例

等待不同类型的多个futures

use futures_concurrency::prelude::*;
use std::future;

let a = future::ready(1u8);
let b = future::ready("hello");
let c = future::ready(3u16);
assert_eq!((a, b, c).join().await, (1, "hello", 3));

并行处理流中的项目

use futures_concurrency::prelude::*;

let v: Vec<_> = vec!["chashu", "nori"]
    .into_co_stream()
    .map(|msg| async move { format!("hello {msg}") })
    .collect()
    .await;

assert_eq!(v, &["hello chashu", "hello nori"]);

在futures的作用域之外访问堆栈数据

改编自 std::thread::scope。

use futures_concurrency::prelude::*;

let mut container = vec![1, 2, 3];
let mut num = 0;

let a = async {
    println!("hello from the first future");
    dbg!(&container);
};

let b = async {
    println!("hello from the second future");
    num += container[0] + container[2];
};

println!("hello from the main future");
let _ = (a, b).join().await;
container.push(4);
assert_eq!(num, container.len());

安装

$ cargo add futures-concurrency

贡献

想要加入我们吗？请查看我们的 "贡献" 指南 并查看一些这些问题

• 标记为 "good first issue" 的问题
• 标记为 "help wanted" 的问题

许可