Решение на упр.09 задача 1 от Никола
Резултати
- 5 точки от тестове
- 0 бонус точки
- 5 точки общо
- 5 успешни тест(а)
- 0 неуспешни тест(а)
Код
use std::collections::HashMap;
use std::sync::{Arc, Mutex, TryLockError};
pub struct Id {
event: String,
id: usize,
}
struct Listener<P> {
id: usize,
f: Box<dyn FnMut(&mut P) + Send>,
}
pub struct EventDispatcher<S> {
inner: Arc<Mutex<Inner<S>>>,
}
struct Inner<S> {
listeners: HashMap<String, Arc<Mutex<Vec<Listener<S>>>>>,
next_id: usize,
}
impl<S> EventDispatcher<S> {
pub fn new() -> Self {
EventDispatcher {
inner: Arc::new(Mutex::new(Inner {
listeners: HashMap::default(),
next_id: 0,
})),
}
}
pub fn on(&self, event: &str, callback: Box<dyn FnMut(&mut S) + Send>) -> Id {
let (next_id, listeners) = {
let mut inner = self.inner.lock().unwrap();
let next_id = inner.next_id;
inner.next_id += 1;
let listeners = inner
.listeners
.entry(event.to_string())
.or_insert_with(|| Arc::new(Mutex::new(vec![])))
.clone();
(next_id, listeners)
};
match listeners.try_lock() {
Ok(mut lock) => lock.push(Listener {
id: next_id,
f: callback,
}),
Err(TryLockError::WouldBlock) => panic!("calling `on` inside `emit` for same event"),
Err(TryLockError::Poisoned(_)) => panic!("poisoned mutex"),
}
Id {
event: event.to_string(),
id: next_id,
}
}
pub fn off(&self, id: Id) -> Option<Box<dyn FnMut(&mut S) + Send>> {
let mut inner = self.inner.lock().unwrap();
let listeners = inner.listeners.get_mut(&id.event)?;
let listeners_lock = listeners.try_lock();
match listeners_lock {
Ok(mut lock) => {
let index = lock.iter().position(|l| l.id == id.id)?;
let l = lock.remove(index);
Some(l.f)
}
Err(TryLockError::WouldBlock) => panic!("calling `off` inside `emit` for same event"),
Err(TryLockError::Poisoned(_)) => panic!("poisoned mutex"),
}
}
pub fn emit(&self, event: &str, state: &mut S) {
let listeners = {
let inner = self.inner.lock().unwrap();
let listeners = match inner.listeners.get(event) {
Some(listeners) => listeners,
None => return,
};
Arc::clone(listeners)
};
let mut lock = match listeners.try_lock() {
Ok(lock) => lock,
Err(TryLockError::WouldBlock) => panic!("calling `emit` inside `emit` for same event"),
Err(TryLockError::Poisoned(_)) => panic!("poisoned mutex"),
};
for l in lock.iter_mut() {
(l.f)(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-core v0.3.31
Compiling futures-sink v0.3.31
Compiling futures-channel v0.3.31
Compiling pin-project-lite v0.2.16
Compiling slab v0.4.11
Compiling syn v2.0.111
Compiling futures-task v0.3.31
Compiling memchr v2.7.6
Compiling pin-utils v0.1.0
Compiling futures-io v0.3.31
Compiling solution v0.1.0 (/tmp/d20251211-1757769-1f1ilkj/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 10.91s
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_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