Решение на упр.09 задача 1 от Димитър Николов
Към профила на Димитър Николов
Резултати
- 5 точки от тестове
- 0 бонус точки
- 5 точки общо
- 5 успешни тест(а)
- 0 неуспешни тест(а)
Код
use std::{
collections::HashMap,
sync::{Arc, Mutex},
};
pub struct Id {
event: String,
callback_idx: usize,
}
type Callback<S> = Box<dyn FnMut(&mut S) + Send>;
type CallbackLookup<S> = HashMap<String, Vec<Option<Callback<S>>>>;
pub struct EventDispatcher<S> {
inner: Arc<Mutex<CallbackLookup<S>>>,
}
impl<S> EventDispatcher<S> {
pub fn new() -> Self {
Self {
inner: Arc::new(Mutex::new(HashMap::new())),
}
}
pub fn on(&self, event: &str, callback: Callback<S>) -> Id {
let event = event.to_string();
let mut map = self.inner.lock().unwrap();
let bucket = map.entry(event.clone()).or_insert(Vec::new());
let state_idx = bucket.len();
bucket.push(Some(callback));
Id {
event,
callback_idx: state_idx,
}
}
pub fn off(&self, id: Id) -> Option<Callback<S>> {
let mut map = self.inner.lock().unwrap();
let bucket = map.get_mut(&id.event)?;
bucket.get_mut(id.callback_idx)?.take()
}
pub fn emit(&self, event: &str, state: &mut S) {
let mut callbacks = {
let mut map = self.inner.lock().unwrap();
map.get_mut(event)
.map(|bucket| std::mem::take(bucket))
.unwrap_or_default()
};
for callback_opt in callbacks.iter_mut() {
if let Some(callback) = callback_opt {
callback(state);
}
}
let mut map = self.inner.lock().unwrap();
if let Some(bucket) = map.get_mut(event) {
*bucket = callbacks;
}
}
}
impl<S> Clone for EventDispatcher<S> {
fn clone(&self) -> Self {
EventDispatcher {
inner: Arc::clone(&self.inner),
}
}
}
Лог от изпълнението
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 slab v0.4.11
Compiling syn v2.0.111
Compiling futures-io v0.3.31
Compiling futures-task v0.3.31
Compiling memchr v2.7.6
Compiling pin-project-lite v0.2.16
Compiling pin-utils v0.1.0
Compiling solution v0.1.0 (/tmp/d20251211-1757769-5gsedj/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.83s
Running tests/solution_test.rs (target/debug/deps/solution_test-ee0783488e12dce9)
running 5 tests
test solution_test::test_basic_run1 ... ok
test solution_test::test_basic_run2 ... ok
test solution_test::test_multithreaded_run1 ... ok
test solution_test::test_multithreaded_run2 ... 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