Решение на упр.09 задача 1 от Виктор Карталов
Към профила на Виктор Карталов
Резултати
- 5 точки от тестове
- 0 бонус точки
- 5 точки общо
- 5 успешни тест(а)
- 0 неуспешни тест(а)
Код
use std::collections::HashMap;
use std::sync::{Arc, Mutex};
use std::sync::atomic::{AtomicU64, Ordering};
#[derive(Clone)]
pub struct Id(u64);
type Callback<S> = Box<dyn FnMut(&mut S) + Send + 'static>;
struct Inner<S> {
next_id: AtomicU64,
events: Mutex<HashMap<String, Vec<(Id, Callback<S>)>>>,
}
pub struct EventDispatcher<S> {
inner: Arc<Inner<S>>,
}
impl<S> EventDispatcher<S> {
pub fn new() -> Self {
EventDispatcher {
inner: Arc::new(Inner {
next_id: AtomicU64::new(1),
events: Mutex::new(HashMap::new()),
}),
}
}
pub fn on(
&self,
event: &str,
callback: Box<dyn FnMut(&mut S) + Send + 'static>,
) -> Id {
let id = Id(self.inner.next_id.fetch_add(1, Ordering::SeqCst));
let mut events = self.inner.events.lock().unwrap();
events.entry(event.to_string())
.or_default()
.push((id.clone(), callback));
id
}
pub fn off(
&self,
id: Id,
) -> Option<Box<dyn FnMut(&mut S) + Send + 'static>> {
let mut events = self.inner.events.lock().unwrap();
for (_, vec) in events.iter_mut() {
if let Some(pos) = vec.iter().position(|(cid, _)| cid.0 == id.0) {
let (_, cb) = vec.remove(pos);
return Some(cb);
}
}
None
}
pub fn emit(&self, event: &str, state: &mut S) {
let mut callbacks: Vec<(Id, Callback<S>)> = {
let mut events = self.inner.events.lock().unwrap();
if let Some(v) = events.get_mut(event) {
// Клонираме векторa, за да пуснем callback-ите извън lock-а
let mut taken = Vec::new();
std::mem::swap(&mut taken, v);
taken
} else {
return;
}
};
for (_, cb) in callbacks.iter_mut() {
cb(state);
}
let mut events = self.inner.events.lock().unwrap();
events.insert(event.to_string(), 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 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 slab v0.4.11
Compiling syn v2.0.111
Compiling futures-task v0.3.31
Compiling pin-project-lite v0.2.16
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-12y7gg3/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.86s
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