Решение на упр.09 задача 1 от Илиян Гаврилов
Резултати
- 5 точки от тестове
- 0 бонус точки
- 5 точки общо
- 5 успешни тест(а)
- 0 неуспешни тест(а)
Код
use std::collections::HashMap;
use std::sync::{Arc, Mutex};
pub struct Id {
id: usize,
event_name: String,
}
struct EventCallbacks<S> {
callbacks: HashMap<usize, Box<dyn FnMut(&mut S) + Send>>,
}
struct Inner<S> {
events: HashMap<String, Arc<Mutex<EventCallbacks<S>>>>,
next_id: usize,
}
pub struct EventDispatcher<S> {
inner: Arc<Mutex<Inner<S>>>,
}
impl<S: Send + 'static> EventDispatcher<S> {
pub fn new() -> Self {
EventDispatcher {
inner: Arc::new(Mutex::new(Inner {
events: HashMap::new(),
next_id: 0,
})),
}
}
pub fn on(
&self,
event: &str,
callback: Box<dyn FnMut(&mut S) + Send>,
) -> Id {
let mut inner_lock = self.inner.lock().unwrap();
let id = inner_lock.next_id;
inner_lock.next_id += 1;
let event_name = event.to_string();
let callbacks_arc = inner_lock
.events
.entry(event_name.clone())
.or_insert_with(|| Arc::new(Mutex::new(EventCallbacks { callbacks: HashMap::new() })))
.clone();
drop(inner_lock);
let mut callbacks_lock = callbacks_arc.lock().unwrap();
callbacks_lock.callbacks.insert(id, callback);
Id { id, event_name }
}
pub fn off(
&self,
id: Id,
) -> Option<Box<dyn FnMut(&mut S) + Send>> {
let inner_lock = self.inner.lock().unwrap();
let callbacks_arc = match inner_lock.events.get(&id.event_name) {
Some(arc) => arc.clone(),
None => return None,
};
drop(inner_lock);
let mut callbacks_lock = callbacks_arc.lock().unwrap();
callbacks_lock.callbacks.remove(&id.id)
}
pub fn emit(&self, event: &str, state: &mut S) {
let inner_lock = self.inner.lock().unwrap();
let callbacks_arc = match inner_lock.events.get(event) {
Some(arc) => arc.clone(),
None => return,
};
drop(inner_lock);
let mut callbacks_lock = callbacks_arc.lock().unwrap();
let ids: Vec<usize> = callbacks_lock.callbacks.keys().cloned().collect();
for id in ids {
if let Some(callback) = callbacks_lock.callbacks.get_mut(&id) {
(callback)(state);
}
}
}
}
impl<S> Clone for EventDispatcher<S> {
fn clone(&self) -> Self {
EventDispatcher { inner: Arc::clone(&self.inner) }
}
}
impl<S: Send + 'static> Default for EventDispatcher<S> {
fn default() -> Self {
Self::new()
}
}
fn main() {
}
// Кога да използваме или да не използваме типове, които се държат като handle-и:
// Типовете, които се държат като handle-и (thin references/lightweight wrappers) са структури, които
// не съдържат директно паметта на обекта, а съдържат умни указатели, като външен ресурс.
// Използват се при:
// - споделено състояние/ресурс - при многонишковост
// - огромни структури, които често се копират/клонират - по-лесно е копирането на пойнтър отколкото на цяла структура, но по този начин се губи локалността
// - лесно освобождаване на заделена памет - рекурсивни структури - графи, списъци
// Не ги използваме при:
// - несподелено състояние/ресурс - само един собственик
// - малки и прости структури
// - ситуации, в които оптимизираме кода и ни трябва производителност, да не губим локалността и да не добавяме bonus overhead
Лог от изпълнението
Updating crates.io index
Locking 17 packages to latest compatible versions
Compiling proc-macro2 v1.0.103
Compiling unicode-ident v1.0.22
Compiling quote v1.0.42
Compiling futures-core v0.3.31
Compiling futures-sink v0.3.31
Compiling futures-channel v0.3.31
Compiling memchr v2.7.6
Compiling syn v2.0.111
Compiling futures-task v0.3.31
Compiling futures-io v0.3.31
Compiling pin-utils v0.1.0
Compiling pin-project-lite v0.2.16
Compiling slab v0.4.11
Compiling solution v0.1.0 (/tmp/d20251211-1757769-121cj4k/solution)
warning: function `main` is never used
--> src/lib.rs:106:4
|
106 | fn main() {
| ^^^^
|
= note: `#[warn(dead_code)]` on by default
warning: `solution` (lib) generated 1 warning
Compiling futures-macro v0.3.31
Compiling futures-util v0.3.31
Compiling futures-executor v0.3.31
Compiling futures v0.3.31
warning: function `main` is never used
--> tests/../src/lib.rs:106:4
|
106 | fn main() {
| ^^^^
|
= note: `#[warn(dead_code)]` on by default
warning: `solution` (test "solution_test") generated 1 warning
Finished `test` profile [unoptimized + debuginfo] target(s) in 8.92s
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