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

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

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

Решение на упр.09 задача 1 от Деян Делчев

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

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

Резултати

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

Код

use std::{
collections::{HashMap, hash_map::ValuesMut},
sync::{Arc, Mutex},
};
pub struct Id {
event: String,
callback_id: i32,
}
type Callback<S> = Box<dyn FnMut(&mut S) + Send>;
struct CallbackStore<S> {
next_callback_id: i32,
callbacks: HashMap<i32, Box<dyn FnMut(&mut S) + Send>>,
}
impl<S> CallbackStore<S> {
fn new() -> Self {
CallbackStore {
next_callback_id: 0,
callbacks: HashMap::new(),
}
}
fn insert(&mut self, callback: Callback<S>) -> i32 {
let id = self.next_callback_id;
self.next_callback_id += 1;
self.callbacks.insert(id, callback);
id
}
fn remove(&mut self, callback_id: i32) -> Option<Callback<S>> {
self.callbacks.remove(&callback_id)
}
}
impl<'a, S> IntoIterator for &'a mut CallbackStore<S> {
type Item = &'a mut Callback<S>;
type IntoIter = ValuesMut<'a, i32, Callback<S>>;
fn into_iter(self) -> Self::IntoIter {
self.callbacks.values_mut()
}
}
pub struct EventDispatcher<S> {
inner: Arc<Mutex<HashMap<String, Arc<Mutex<CallbackStore<S>>>>>>,
}
impl<S> EventDispatcher<S> {
pub fn new() -> Self {
EventDispatcher {
inner: Arc::new(Mutex::new(HashMap::new())),
}
}
fn get_callback_store_by_event(&self, event: &str) -> Arc<Mutex<CallbackStore<S>>> {
self.inner
.lock()
.unwrap()
.entry(event.to_owned())
.or_insert(Arc::new(Mutex::new(CallbackStore::new())))
.clone()
}
pub fn on(&self, event: &str, callback: Box<dyn FnMut(&mut S) + Send>) -> Id {
let callback_store = self.get_callback_store_by_event(event);
let callback_id = callback_store.lock().unwrap().insert(callback);
Id {
event: event.to_owned(),
callback_id,
}
}
pub fn off(&self, id: Id) -> Option<Box<dyn FnMut(&mut S) + Send>> {
let callback_store = self.get_callback_store_by_event(&id.event);
let callback = callback_store.lock().unwrap().remove(id.callback_id);
callback
}
pub fn emit(&self, event: &str, state: &mut S) {
let callback_store = self.get_callback_store_by_event(event);
for callback in callback_store.lock().unwrap().into_iter() {
callback(state);
}
}
}
impl<S> Clone for EventDispatcher<S> {
fn clone(&self) -> Self {
Self {
inner: self.inner.clone(),
}
}
}

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

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-core v0.3.31
   Compiling futures-sink v0.3.31
   Compiling futures-channel v0.3.31
   Compiling pin-utils v0.1.0
   Compiling memchr v2.7.6
   Compiling syn v2.0.111
   Compiling futures-io v0.3.31
   Compiling pin-project-lite v0.2.16
   Compiling slab v0.4.11
   Compiling futures-task v0.3.31
   Compiling solution v0.1.0 (/tmp/d20251211-1757769-169k55a/solution)
   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 8.88s
     Running tests/solution_test.rs (target/debug/deps/solution_test-ee0783488e12dce9)

running 5 tests
test solution_test::test_basic_run2 ... ok
test solution_test::test_basic_run1 ... ok
test solution_test::test_multithreaded_run2 ... ok
test solution_test::test_multithreaded_run1 ... ok
test solution_test::test_reentrant_run ... ok

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

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

Деян качи първо решение на 10.12.2025 03:18 (преди около 2 месеца)

Какво ще стане, ако от callback функция извикаме някой от on или off методите?

Ако event-ите са различени, всичко ще е наред, защото всеки има собствен Mutex.

Ако event-ите са еднакви, ще се получи deadlock, защото докато изпълняваме callbacks Mutex-а ще се заключи, но on или off също имат нужда от Mutex-a и ще чакат вечно.

Най-простото решение е при извикването на callbacks, те да се клонират и сложат във вектор. Така извикването им ще става извън Mutex-а ще се освободи, и така извикването им ще е извън критична зона.

Недостатъкът е, че за всеки emit ще се трябва да се заделя памет и копира, което потенциално има линейна сложност.

Тест, който показва проблема с deadlock-a

fn test_mine() { with_timeout(std::time::Duration::from_secs(3), || { let ed = EventDispatcher::<()>::new(); let callback: Callback<()> = { let ed = ed.clone(); Box::new(move || { ed.on("foo", Box::new(|| println!("hello"))); }) }; ed.on("foo", callback); ed.emit("foo", &mut ()); }); } }