Решение на упр.11 задача 1 от Нели Илиева
Резултати
- 4 точки от тестове
- 0 бонус точки
- 4 точки общо
- 1 успешни тест(а)
- 0 неуспешни тест(а)
Код
use std::time::Duration;
use std::io::Write;
use tokio::time::sleep;
async fn run_task(id: usize, duration: Duration) -> Result<String, String> {
sleep(duration).await;
if duration > Duration::from_millis(800) {
Err(format!("Task {} timed out", id))
}
else {
Ok(format!("Task {} finished in {} ms", id, duration.as_millis()))
}
}
async fn manage_tasks(task_infos: &[(usize, Duration)], w: &mut dyn Write) {
let mut handles = Vec::new();
for &(id, duration) in task_infos {
let handle = tokio::spawn(async move {run_task(id, duration).await});
handles.push(handle);
}
let mut successful = 0;
let mut failed = 0;
for handle in handles {
match handle.await {
Ok(result) => {
match result {
Ok(msg) => {
writeln!(w, "{}", msg).unwrap();
successful += 1;
}
Err(err) => {
writeln!(w, "{}", err).unwrap();
failed += 1;
}
}
}
Err(_) => {
failed += 1;
}
}
}
writeln!(w, "Successful tasks: {}", successful).unwrap();
writeln!(w, "Failed tasks: {}", failed).unwrap();
}
#[tokio::main]
async fn main() {
let tasks = vec![
(1, Duration::from_millis(300)),
(2, Duration::from_millis(900)),
(3, Duration::from_millis(500)),
(4, Duration::from_millis(850)),
(5, Duration::from_millis(200)),
];
let mut output = Vec::new();
manage_tasks(&tasks, &mut output).await;
println!("{}", String::from_utf8(output).unwrap());
}
Лог от изпълнението
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 parking_lot_core v0.9.12
Compiling pin-project-lite v0.2.16
Compiling futures-core v0.3.31
Compiling futures-channel v0.3.31
Compiling memchr v2.7.6
Compiling pin-utils v0.1.0
Compiling cfg-if v1.0.4
Compiling smallvec v1.15.1
Compiling scopeguard v1.2.0
Compiling slab v0.4.11
Compiling futures-task v0.3.31
Compiling futures-io v0.3.31
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 futures-util v0.3.31
Compiling mio v1.1.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-1709np2/solution)
warning: function `run_task` is never used
--> src/lib.rs:5:10
|
5 | async fn run_task(id: usize, duration: Duration) -> Result<String, String> {
| ^^^^^^^^
|
= note: `#[warn(dead_code)]` on by default
warning: function `manage_tasks` is never used
--> src/lib.rs:16:10
|
16 | async fn manage_tasks(task_infos: &[(usize, Duration)], w: &mut dyn Write) {
| ^^^^^^^^^^^^
warning: function `main` is never used
--> src/lib.rs:52:10
|
52 | async fn main() {
| ^^^^
warning: `solution` (lib) generated 3 warnings
warning: function `main` is never used
--> tests/../src/lib.rs:52:10
|
52 | async fn main() {
| ^^^^
|
= note: `#[warn(dead_code)]` on by default
warning: `solution` (test "solution_test") generated 1 warning
Finished `test` profile [unoptimized + debuginfo] target(s) in 17.57s
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