Решение на упр.09 задача 1 от Нели Илиева
Резултати
- 5 точки от тестове
- 0 бонус точки
- 5 точки общо
- 5 успешни тест(а)
- 0 неуспешни тест(а)
Код
use std::collections::HashMap;
use std::sync::{Arc, Mutex};
#[derive(Debug, Clone, Copy, PartialEq, Eq, Hash)]
pub struct Id {
event_key: u64,
callback_id: u64,
}
struct EventCallbacks<S> {
next_id: u64,
callbacks: HashMap<u64, Box<dyn FnMut(&mut S) + Send>>,
}
impl<S> EventCallbacks<S> {
fn new() -> Self {
EventCallbacks {
next_id: 0,
callbacks: HashMap::new(),
}
}
}
struct Inner<S> {
next_event_key: u64,
event_map: HashMap<String, u64>,
event_callbacks: HashMap<u64, Arc<Mutex<EventCallbacks<S>>>>,
}
pub struct EventDispatcher<S> {
inner: Arc<Mutex<Inner<S>>>,
}
impl<S> EventDispatcher<S> {
pub fn new() -> Self {
EventDispatcher {
inner: Arc::new(Mutex::new(Inner {
next_event_key: 0,
event_map: HashMap::new(),
event_callbacks: HashMap::new(),
})),
}
}
pub fn on(
&self,
event: &str,
callback: Box<dyn FnMut(&mut S) + Send>,
) -> Id {
let mut inner = self.inner.lock().unwrap();
let event_key = if let Some(&key) = inner.event_map.get(event) {
key
}
else {
let key = inner.next_event_key;
inner.next_event_key += 1;
inner.event_map.insert(event.to_string(), key);
inner.event_callbacks.insert(
key,
Arc::new(Mutex::new(EventCallbacks::new())),
);
key
};
let callbacks_mutex = Arc::clone(
inner.event_callbacks.get(&event_key).unwrap()
);
drop(inner);
let mut callbacks = callbacks_mutex.lock().unwrap();
let callback_id = callbacks.next_id;
callbacks.next_id += 1;
callbacks.callbacks.insert(callback_id, callback);
Id {
event_key,
callback_id,
}
}
pub fn off(
&self,
id: Id,
) -> Option<Box<dyn FnMut(&mut S) + Send>> {
let inner = self.inner.lock().unwrap();
let callbacks_mutex = inner.event_callbacks.get(&id.event_key)?;
let callbacks_mutex = Arc::clone(callbacks_mutex);
drop(inner);
let mut callbacks = callbacks_mutex.lock().unwrap();
callbacks.callbacks.remove(&id.callback_id)
}
pub fn emit(&self, event: &str, state: &mut S) {
let inner = self.inner.lock().unwrap();
let event_key = match inner.event_map.get(event) {
Some(&key) => key,
None => return,
};
let callbacks_mutex = match inner.event_callbacks.get(&event_key) {
Some(mutex) => Arc::clone(mutex),
None => return,
};
drop(inner);
let mut callbacks = callbacks_mutex.lock().unwrap();
for callback in callbacks.callbacks.values_mut() {
callback(state);
}
}
}
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 futures-task v0.3.31
Compiling futures-io v0.3.31
Compiling memchr v2.7.6
Compiling syn v2.0.111
Compiling slab v0.4.11
Compiling pin-utils v0.1.0
Compiling pin-project-lite v0.2.16
Compiling solution v0.1.0 (/tmp/d20251211-1757769-1jnsb63/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.93s
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