エグゼキュータをブロックする

ほとんどの async ランタイムでは、並行して実行できるのは I/O タスクだけです。これは、CPU をブロックするタスクがエグゼキュータをブロックし、ほかのタスクの実行を妨げることを意味します。簡単な回避策は、可能な場合は async 相当のメソッドを使うことです。

// 著作権 2024 Google LLC
// SPDX-License-Identifier: Apache-2.0

use futures::future::join_all;
use std::time::Instant;

async fn sleep_ms(start: &Instant, id: u64, duration_ms: u64) {
    std::thread::sleep(std::time::Duration::from_millis(duration_ms));
    println!(
        "future {id} slept for {duration_ms}ms, finished after {}ms",
        start.elapsed().as_millis()
    );
}

#[tokio::main(flavor = "current_thread")]
async fn main() {
    let start = Instant::now();
    let sleep_futures = (1..=10).map(|t| sleep_ms(&start, t, t * 10));
    join_all(sleep_futures).await;
}