■ Duration 구조체의 from_millis 연관 함수를 사용해 밀리초 단위 Duration 객체를 구하는 방법을 보여준다. ▶ 예제 코드 (RS)
|
1 2 3 4 5 |
use tokio::time; let duration : time::Duration = time::Duration::from_millis(1000); |
■ join! 매크로를 사용해 비동기 병렬 처리 완료시까지 대기하는 방법을 보여준다. ▶ Cargo.toml
|
1 2 3 4 5 6 7 8 9 |
[package] name = "test_project" version = "0.1.0" edition = "2021" [dependencies] tokio = { version = "1", features = ["full"] } |
▶ src/main.rs
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 |
use tokio::time; async fn print_message_async(second_count : u64, message : &str) { time::sleep(time::Duration::from_secs(second_count)).await; println!("{} : {}", second_count, message); } #[tokio::main] async fn main() { tokio::spawn(print_message_async(3, "메시지 #1")); tokio::spawn(print_message_async(2, "메시지 #2")); tokio::spawn(print_message_async(1, "메시지 #3")); time::sleep(time::Duration::from_secs(4)).await; println!("------------"); tokio::join! ( print_message_async(2, "메시지 #4"), print_message_async(3, "메시지 #5"), print_message_async(1, "메시지 #6") ); } |
test_project.zip
■ spawn 함수를 사용해 비동기 병렬 처리하는 방법을 보여준다. ▶ Cargo.toml
|
1 2 3 4 5 6 7 8 9 |
[package] name = "test_project" version = "0.1.0" edition = "2021" [dependencies] tokio = { version = "1", features = ["full"] } |
▶ src/main.rs
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 |
use tokio::time; async fn print_message_async(second_count : u64, message : &str) { time::sleep(time::Duration::from_secs(second_count)).await; println!("{} : {}", second_count, message); } #[tokio::main] async fn main() { tokio::spawn(print_message_async(3, "메시지 #1")); tokio::spawn(print_message_async(2, "메시지 #2")); tokio::spawn(print_message_async(1, "메시지 #3")); time::sleep(time::Duration::from_secs(4)).await; } |
test_project.zip
■ 블럭문을 사용해 비동기 처리를 하는 방법을 보여준다. ▶ Cargo.toml
|
1 2 3 4 5 6 7 8 9 |
[package] name = "test_project" version = "0.1.0" edition = "2021" [dependencies] tokio = { version = "1", features = ["full"] } |
▶ src/main.rs
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 |
use tokio::time; #[tokio::main] async fn main() { for i in 1..=3 { println!("#{} START TO GET MESSAGE", i); let message = async { time::sleep(time::Duration::from_secs(1)).await; return String::from(format!("MESSAGE {}", i)); }.await; println!("{}", message); } } |
test_project.zip
■ tokio 크레이트를 사용해 반환값을 갖는 비동기 처리를 하는 방법을 보여준다. ▶ Cargo.toml
|
1 2 3 4 5 6 7 8 9 |
[package] name = "test_project" version = "0.1.0" edition = "2021" [dependencies] tokio = { version = "1", features = ["full"] } |
▶ src/main.rs
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 |
use tokio::time; #[tokio::main] async fn main() { for i in 1..=3 { println!("#{} START TO GET MESSAGE", i); let message : String = get_message_async(i).await; println!("{}", message); } } async fn get_message_async(value : i32) -> String { time::sleep(time::Duration::from_secs(1)).await; return String::from(format!("MESSAGE {}", value)); } |
test_project.zip
■ sleep 함수를 사용해 실행을 일정 시간 동안 대기하는 방법을 보여준다. ▶ 예제 코드 (RS)
|
1 2 3 4 5 6 7 |
use tokio::time; let duration : time::Duration = time::Duration::from_secs(1); time::sleep(duration).await; |
■ Duration 구조체의 from_secs 연관 함수를 사용해 초단위 Duration 객체를 구하는 방법을 보여준다. ▶ 예제 코드 (RS)
|
1 2 3 4 5 |
use tokio::time; let duration : time::Duration = time::Duration::from_secs(1); |
■ tokio 크레이트를 사용해 비동기 처리를 하는 방법을 보여준다. ▶ Cargo.toml
|
1 2 3 4 5 6 7 8 9 |
[package] name = "test_project" version = "0.1.0" edition = "2021" [dependencies] tokio = { version = "1", features = ["full"] } |
▶ src/main.rs
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 |
#[tokio::main] async fn main() { let future = print_message_async("메시지 #1"); println!("메시지 #2"); future.await; } async fn print_message_async(message : &'static str) { println!("{}", message); } |
test_project.zip
■ tokio 크레이트를 설치하는 방법을 보여준다. ▶ Cargo.toml
|
1 2 3 4 5 6 |
... [dependencies] tokio = { version = "1", features = ["full"] } |