做推广都有哪些网站,建设银行企业网站无法打印回单,网站代码制作,合同下载网站只用 .await 来执行future，会阻塞并发任务，直到特定的 Future 完成
join!：等待所有future完成
可事实上为什么都是res1完成后再执行res2？ join! 不保证并发执行，难道只负责同步等待？
示例
[package]
name = rust_demo5
version = 0.1.0
edit…只用 .await 来执行future，会阻塞并发任务，直到特定的 Future 完成
join!：等待所有future完成
可事实上为什么都是res1完成后再执行res2？ join! 不保证并发执行，难道只负责同步等待？
示例
[package]
name = "rust_demo5"
version = "0.1.0"
edition = "2021"[dependencies]
futures = "0.3"
tokio = { version = "1.16.0", features = ["full"] }
tokio-stream = "0.1.14"use futures::executor::block_on;
use std::thread::sleep;
use std::thread;
use std::time::Duration;
use futures::{future, join};async fn task_one() {println!("task_one: begin");thread::sleep(Duration::from_secs(4));println!("task_one: finish");
}async fn task_two() {println!("task_two: begin");thread::sleep(Duration::from_secs(2));println!("task_two: finish");
}#[tokio::main]
async fn main() {let (res1, res2) = join!(task_one(), task_two());// 在这里调用 res1 和 res2，它们分别对应异步任务1和异步任务2的输出结果// 先执行完task_one，再执行完task_two，然后再返回
}use futures::executor::block_on;
use std::thread;
use futures::{future, join};async fn task_one() {println!("task_one: begin");for i in 1..=10_000_000 {if i % 100_000 == 0 {println!("task_one, found a number: {}", i);}}println!("task_one: finish");
}async fn task_two() {println!("task_two: begin");for i in 1..=10_000_000 {if i % 100_000 == 0 {println!("task_two, found a number: {}", i);}}println!("task_two: finish");
}#[tokio::main]
async fn main() {let (res1, res2) = join!(task_one(), task_two());// 在这里调用 res1 和 res2，它们分别对应异步任务1和异步任务2的输出结果
}反例
不必在 get_book 完成后再 get_music
async fn get_book_and_music() - (Book, Music) {let book = get_book().await;let music = get_music().await;(book, music)
}try_join
返回 Result 的 future，考虑使用 try_join! 而非 join join 只会在所有子 future 都完成后才会完成，它甚至会在子 future 返回 Err 之后继续处理 try_join! 会在其中的子future返回错误后立即完成
use futures::try_join;async fn get_book() - ResultBook, String { /* ... */ Ok(Book) }
async fn get_music() - ResultMusic, String { /* ... */ Ok(Music) }async fn get_book_and_music() - Result(Book, Music), String {let book_fut = get_book();let music_fut = get_music();try_join!(book_fut, music_fut)
}传进 try_join! 的 future 必须要用相同的错误类型。 考虑使用 futures::future::TryFutureExt 库的 .map_err(|e| …) 或 err_into() 函数来统一错误类型：
use futures::{future::TryFutureExt,try_join,
};// Result 类型用于更好地处理和组织错误情况，并在避免出现非预期错误时提供便捷// 一种是一个内部类型为 Book 的成功结果，另一个是一个无内部类型 () 的错误结果
async fn
