Решение на упр.11 задача 1 от Георги Стоянов

Обратно към всички решения

Към профила на Георги Стоянов

Код

use std::io::Write;

use std::time::Duration;

use tokio::time::sleep;

const TIMEOUT_MS: u64 = 800;

pub async fn run_task(id: usize, duration: Duration) -> Result<String, String> {

sleep(duration).await;

if duration > Duration::from_millis(TIMEOUT_MS) {

return Err(format!("Task {} timed out", id));

}

Ok(format!(

"Task {} finished in {} ms",

id,

duration.as_millis()

))

}

pub async fn manage_tasks(task_infos: &[(usize, Duration)], w: &mut dyn Write) {

// 1) старт на всички задачи ПАРАЛЕЛНО (spawn), без да await-ваме веднага

let mut handles = Vec::with_capacity(task_infos.len());

for &(id, duration) in task_infos {

handles.push(tokio::spawn(async move { run_task(id, duration).await }));

}

let mut ok_cnt: usize = 0;

let mut err_cnt: usize = 0;

for h in handles {

match h.await {

Ok(Ok(msg)) => {

ok_cnt += 1;

let _ = writeln!(w, "{}", msg);

}

Ok(Err(err)) => {

err_cnt += 1;

let _ = writeln!(w, "{}", err);

}

Err(join_err) => {

err_cnt += 1;

let _ = writeln!(w, "Task failed to join: {}", join_err);

}

}

}

let _ = writeln!(w, "Successful tasks: {}", ok_cnt);

let _ = writeln!(w, "Failed tasks: {}", err_cnt);

}

Лог от изпълнението

Updating crates.io index
     Locking 46 packages to latest compatible versions
   Compiling proc-macro2 v1.0.104
   Compiling unicode-ident v1.0.22
   Compiling quote v1.0.42
   Compiling libc v0.2.178
   Compiling syn v2.0.111
   Compiling futures-sink v0.3.31
   Compiling pin-project-lite v0.2.16
   Compiling parking_lot_core v0.9.12
   Compiling futures-core v0.3.31
   Compiling futures-channel v0.3.31
   Compiling slab v0.4.11
   Compiling scopeguard v1.2.0
   Compiling cfg-if v1.0.4
   Compiling futures-io v0.3.31
   Compiling futures-task v0.3.31
   Compiling pin-utils v0.1.0
   Compiling memchr v2.7.6
   Compiling smallvec v1.15.1
   Compiling lock_api v0.4.14
   Compiling errno v0.3.14
   Compiling signal-hook-registry v1.4.8
   Compiling parking_lot v0.12.5
   Compiling socket2 v0.6.1
   Compiling futures-macro v0.3.31
   Compiling tokio-macros v2.6.0
   Compiling mio v1.1.1
   Compiling futures-util v0.3.31
   Compiling bytes v1.11.0
   Compiling tokio v1.48.0
   Compiling futures-executor v0.3.31
   Compiling futures v0.3.31
   Compiling solution v0.1.0 (/tmp/d20251228-4108951-1ihj5pz/solution)
    Finished `test` profile [unoptimized + debuginfo] target(s) in 17.67s
     Running tests/solution_test.rs (target/debug/deps/solution_test-f512224d9fb3caf8)

running 1 test
test solution_test::test_basic ... ok

test result: ok. 1 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 1.20s

История (1 версия и 0 коментара)