只用 .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返回错误后立即完成文章来源:https://www.toymoban.com/news/detail-646589.html
use futures::try_join;
async fn get_book() -> Result<Book, String> {
/* ... */ Ok(Book) }
async fn get_music() -> Result<Music, 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() 函数来统一错误类型:文章来源地址https://www.toymoban.com/news/detail-646589.html
use futures::{
future::TryFutureExt,
try_join,
};
// Result 类型用于更好地处理和组织错误情况,并在避免出现非预期错误时提供便捷
// 一种是一个内部类型为 Book 的成功结果,另一个是一个无内部类型 () 的错误结果
async fn
到了这里,关于rust学习-同时执行多Future的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!