Derive + Generic структури

Програмиране с Rust

Курс във Факултета по Математика и Информатика към СУ

Решение на Домашно 1 - търсене на съкровища от Йоанна Ненкова

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

Към профила на Йоанна Ненкова

Резултати

  • 20 точки от тестове
  • 0 бонус точки
  • 20 точки общо
  • 5 успешни тест(а)
  • 0 неуспешни тест(а)

Код

use std::collections::HashMap;
use std::sync::{Arc, Mutex, Condvar};
#[derive(Debug, Clone, PartialEq, Eq)]
pub struct TreasureLoc {
pub lane_index: usize,
pub cell_coord: usize,
pub value: i32,
}
#[derive(Debug, PartialEq, Eq)]
pub enum FoundTreasures {
Big(TreasureLoc),
Small(Vec<TreasureLoc>),
Nothing,
}
struct SharedState {
small_treasures: HashMap<usize, TreasureLoc>,
big_tresure: Option<TreasureLoc>,
active_drones: usize,
stop_signal: bool,
}
pub struct Scan<'a> {
pub start_coord: usize,
pub cells: &'a [i32],
}
pub struct Drone {
lane_index: usize,
shared: Arc<(Mutex<SharedState>, Condvar)>,
}
impl Drone {
pub fn explore(&mut self, scanner: &mut dyn Iterator<Item = Scan<'_>>) {
let mut best_small: Option<TreasureLoc> = None;
for scan in scanner {
{
let (lock, _) = &*self.shared;
let state = lock.lock().unwrap();
if state.stop_signal {
break;
}
}
for (i, &value) in scan.cells.iter().enumerate() {
if value > 0 {
let t = TreasureLoc {
lane_index: self.lane_index,
cell_coord: scan.start_coord + i,
value,
};
if value >= 999 {
let (lock, cvar) = &*self.shared;
let mut state = lock.lock().unwrap();
state.big_tresure = Some(t);
state.stop_signal = true;
cvar.notify_all();
state.active_drones -= 1;
cvar.notify_all();
return;
}
if best_small.is_none() || value > best_small.as_ref().unwrap().value {
best_small = Some(t);
}
}
}
}
let (lock, cvar) = &*self.shared;
let mut state = lock.lock().unwrap();
if let Some(treasure) = best_small {
state.small_treasures.insert(self.lane_index, treasure);
}
state.active_drones -= 1;
let total: i32 = state.small_treasures.values().map(|t| t.value).sum();
if total >= 300 {
state.stop_signal = true;
}
cvar.notify_all();
}
}
pub struct DroneController {
shared: Arc<(Mutex<SharedState>, Condvar)>,
drone_count: usize,
}
impl DroneController {
pub fn new() -> Self {
Self {
shared: Arc::new((
Mutex::new(SharedState {
small_treasures: HashMap::new(),
big_tresure: None,
active_drones: 0,
stop_signal: false,
}),
Condvar::new(),
)),
drone_count: 0,
}
}
pub fn create_drone(&mut self, lane_index: usize) -> Drone {
{
let (lock, _) = &*self.shared;
let mut state = lock.lock().unwrap();
state.active_drones += 1;
}
self.drone_count += 1;
Drone {
lane_index,
shared: Arc::clone(&self.shared),
}
}
pub fn run(&mut self) -> FoundTreasures {
let (lock, cvar) = &*self.shared;
let mut state = lock.lock().unwrap();
while state.active_drones > 0 {
if let Some(ref big) = state.big_tresure {
return FoundTreasures::Big(big.clone());
}
let total: i32 = state.small_treasures.values().map(|t| t.value).sum();
if total >= 300 {
let treasures = state.small_treasures.values().cloned().collect();
return FoundTreasures::Small(treasures);
}
state = cvar.wait(state).unwrap();
}
if let Some(ref big) = state.big_tresure {
return FoundTreasures::Big(big.clone());
}
let total: i32 = state.small_treasures.values().map(|t: &TreasureLoc| t.value).sum();
if total >= 300 {
let treasures = state.small_treasures.values().cloned().collect();
return FoundTreasures::Small(treasures);
}
FoundTreasures::Nothing
}
}
const fn assert_send_static<T: Send + 'static>() {}
const _: () = assert_send_static::<DroneController>();
const _: () = assert_send_static::<Drone>();

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

Updating crates.io index
     Locking 46 packages to latest compatible versions
   Compiling proc-macro2 v1.0.104
   Compiling quote v1.0.42
   Compiling libc v0.2.178
   Compiling unicode-ident v1.0.22
   Compiling syn v2.0.111
   Compiling pin-project-lite v0.2.16
   Compiling parking_lot_core v0.9.12
   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 scopeguard v1.2.0
   Compiling cfg-if v1.0.4
   Compiling pin-utils v0.1.0
   Compiling futures-io v0.3.31
   Compiling smallvec v1.15.1
   Compiling slab v0.4.11
   Compiling memchr v2.7.6
   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 mio v1.1.1
   Compiling futures-macro v0.3.31
   Compiling tokio-macros v2.6.0
   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/d20251229-4108951-f9p5lp/solution)
warning: function `assert_send_static` is never used
   --> src/lib.rs:160:10
    |
160 | const fn assert_send_static<T: Send + 'static>() {}
    |          ^^^^^^^^^^^^^^^^^^
    |
    = note: `#[warn(dead_code)]` on by default

warning: `solution` (lib) generated 1 warning
    Finished `test` profile [unoptimized + debuginfo] target(s) in 18.42s
     Running tests/solution_test.rs (target/debug/deps/solution_test-f512224d9fb3caf8)

running 5 tests
test solution_test::test_big_treasure ... ok
test solution_test::test_nothing ... ok
test solution_test::test_small_treasure ... ok
test solution_test::test_small_treasure_2 ... ok
test solution_test::test_return_immediately_when_found ... ok

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

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

Йоанна качи първо решение на 23.12.2025 20:42 (преди около 1 месеца)

Имаш пропуск в решението. Не си имплементирала спиране на дроновете, когато сборът от намерените до момента малки съкровища стигне 300. Ако итераторите scanner са безкрайни, решението ти никога няма да върне FoundTreasure::Small(_), дори след като всичко нужно е намерено.

Но съм пропуснал да добавя тест за този случай.