Решение на упр.11 задача 1 от Мариян Момчилов

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

Към профила на Мариян Момчилов

Код

use std::io::Write;

use std::time::{self, Duration};

use tokio::runtime::{Builder, Runtime};

use tokio::time::sleep;

const MS_LIMIT: u128 = 800;

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

let now = time::Instant::now();

sleep(duration).await;

let elapsed_ms = now.elapsed().as_millis();

if elapsed_ms > MS_LIMIT {

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

}

Ok(format!("Task {id} finished in {} ms", duration.as_millis()))

}

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

let tasks = task_infos

.iter()

.map(|t_i| tokio::task::spawn(run_task(t_i.0, t_i.1)));

let mut failed_tasks: usize = 0;

for task_f in tasks {

let result = task_f.await;

let _ = match result {

Ok(Ok(s)) => writeln!(w, "{}", s),

Ok(Err(s)) => {

failed_tasks += 1;

writeln!(w, "{}", s)

}

Err(_) => writeln!(w, "Join Error"),

};

}

let _ = writeln!(w, "Successful tasks: {}", task_infos.len() - failed_tasks);

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

}

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

Updating crates.io index
     Locking 46 packages to latest compatible versions
   Compiling proc-macro2 v1.0.104
   Compiling quote v1.0.42
   Compiling unicode-ident v1.0.22
   Compiling libc v0.2.178
   Compiling syn v2.0.111
   Compiling pin-project-lite v0.2.16
   Compiling futures-core v0.3.31
   Compiling parking_lot_core v0.9.12
   Compiling futures-sink v0.3.31
   Compiling futures-channel v0.3.31
   Compiling scopeguard v1.2.0
   Compiling memchr v2.7.6
   Compiling pin-utils v0.1.0
   Compiling cfg-if v1.0.4
   Compiling futures-io v0.3.31
   Compiling futures-task v0.3.31
   Compiling smallvec v1.15.1
   Compiling slab v0.4.11
   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 mio v1.1.1
   Compiling futures-macro v0.3.31
   Compiling tokio-macros v2.6.0
   Compiling futures-util v0.3.31
   Compiling socket2 v0.6.1
   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-15ajd19/solution)
warning: unused imports: `Builder` and `Runtime`
 --> src/lib.rs:3:22
  |
3 | use tokio::runtime::{Builder, Runtime};
  |                      ^^^^^^^  ^^^^^^^
  |
  = note: `#[warn(unused_imports)]` on by default

warning: constant `MS_LIMIT` is never used
 --> src/lib.rs:6:7
  |
6 | const MS_LIMIT: u128 = 800;
  |       ^^^^^^^^
  |
  = note: `#[warn(dead_code)]` on by default

warning: function `run_task` is never used
 --> src/lib.rs:8:10
  |
8 | async fn run_task(id: usize, duration: Duration) -> Result<String, String> {
  |          ^^^^^^^^

warning: function `manage_tasks` is never used
  --> src/lib.rs:18:10
   |
18 | async fn manage_tasks(task_infos: &[(usize, Duration)], w: &mut dyn Write) {
   |          ^^^^^^^^^^^^

warning: `solution` (lib) generated 4 warnings (run `cargo fix --lib -p solution` to apply 1 suggestion)
warning: unused imports: `Builder` and `Runtime`
 --> tests/../src/lib.rs:3:22
  |
3 | use tokio::runtime::{Builder, Runtime};
  |                      ^^^^^^^  ^^^^^^^
  |
  = note: `#[warn(unused_imports)]` on by default

warning: `solution` (test "solution_test") generated 1 warning (run `cargo fix --test "solution_test"` to apply 1 suggestion)
    Finished `test` profile [unoptimized + debuginfo] target(s) in 17.70s
     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 3.11s

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