[rust] tokio 비동기 동시 처리 기본 예시 코드

tokio를 통한 async 작업을 동시 실행. dotnet의 Task.WaitAll() 과 유사

입력받은 초(sec)만큼 시간이 출력되는 작업 print_now를 각각 f1, f2 작업을 만들어 동시 실행 처리.

 

tokio::join으로 들어온 작업 중 가장 늦게 끝난 작업 기준으로 종료

 

[main.rs]

use tokio;
use time::{OffsetDateTime}; // 포맷팅된 시간 글자를 표기하기위한 라이브러리

#[tokio::main]
async fn main() {
    let f1 = print_now(1, 5);
    let f2 = print_now(2, 10);
    tokio::join!(f1, f2); // f1, f2
}

// 1초당 현재시간(UTC) 표기
async fn print_now(id: i32, sec: i32) {
    let mut i = 0;
    while i < sec {
        println!("print{}, {}", id, OffsetDateTime::now_utc());
        tokio::time::sleep(tokio::time::Duration::from_secs(1)).await;
        i += 1;
    }
}

 

[Cargo.toml]

[package]
name = "tokio-test"
version = "0.1.0"
edition = "2021"

[dependencies]
tokio = { version = "1.41.1", features = ["full"]}
time = "0.3.36"