Решение на упр.10 задача 1 от Ясин Йосифов
Резултати
- 2 точки от тестове
- 0 бонус точки
- 2 точки общо
- 2 успешни тест(а)
- 0 неуспешни тест(а)
Код
use std::thread;
enum Predicate {
GreaterThan100,
Even,
Prime,
DivisibleBy7,
}
fn is_prime(num: i32) -> bool {
let num = num.abs() as u32;
if num <= 1 {
return false;
}
for i in 2..=(num as f64).sqrt() as u32 {
if num % i == 0 {
return false;
}
}
true
}
fn parallel_filter(data: Vec<i32>, n_threads: usize, predicate: Predicate) -> Vec<i32> {
let mut finalvec = Vec::<i32>::new();
let count = data.len() / n_threads;
let count = if count == 0 { 1 } else { count };
thread::scope(|s| {
let mut handles = vec![];
for i in 0 .. n_threads {
let mut slice = &data[i * count .. (i + 1) * count];
if i == n_threads - 1 {
slice = &data[i * count .. data.len()];
}
handles.push(s.spawn(|| {
match &predicate {
Predicate::GreaterThan100 => slice.iter().filter(|&x| *x > 100).collect::<Vec<_>>(),
Predicate::Even => slice.iter().filter(|&x| *x % 2 == 0).collect::<Vec<_>>(),
Predicate::Prime => slice.iter().filter(|&x| is_prime(*x)).collect::<Vec<_>>(),
Predicate::DivisibleBy7 => slice.iter().filter(|&x| *x % 7 == 0).collect::<Vec<_>>(),
}
}));
}
for h in handles {
let vec = h.join().unwrap();
for i in vec {
finalvec.push(*i);
}
}
});
finalvec
}
Лог от изпълнението
Updating crates.io index
Locking 17 packages to latest compatible versions
Compiling proc-macro2 v1.0.103
Compiling quote v1.0.42
Compiling unicode-ident v1.0.22
Compiling futures-sink v0.3.31
Compiling futures-core v0.3.31
Compiling futures-channel v0.3.31
Compiling futures-task v0.3.31
Compiling syn v2.0.111
Compiling pin-project-lite v0.2.16
Compiling slab v0.4.11
Compiling pin-utils v0.1.0
Compiling futures-io v0.3.31
Compiling memchr v2.7.6
Compiling solution v0.1.0 (/tmp/d20251218-1757769-mo6p07/solution)
warning: enum `Predicate` is never used
--> src/lib.rs:3:6
|
3 | enum Predicate {
| ^^^^^^^^^
|
= note: `#[warn(dead_code)]` on by default
warning: function `is_prime` is never used
--> src/lib.rs:10:4
|
10 | fn is_prime(num: i32) -> bool {
| ^^^^^^^^
warning: function `parallel_filter` is never used
--> src/lib.rs:26:4
|
26 | fn parallel_filter(data: Vec<i32>, n_threads: usize, predicate: Predicate) -> Vec<i32> {
| ^^^^^^^^^^^^^^^
warning: `solution` (lib) generated 3 warnings
Compiling futures-macro v0.3.31
Compiling futures-util v0.3.31
Compiling futures-executor v0.3.31
Compiling futures v0.3.31
Finished `test` profile [unoptimized + debuginfo] target(s) in 9.17s
Running tests/solution_test.rs (target/debug/deps/solution_test-ee0783488e12dce9)
running 2 tests
test solution_test::test_basic ... ok
test solution_test::test_uneven_split ... ok
test result: ok. 2 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.00s