mirror of
https://github.com/salsa-rs/salsa.git
synced 2024-10-24 21:24:20 +00:00
0e01067d55
Quickest POC I could create to get some potentially cyclic queries to not panic and instead return a result I could act on. (gluon's module importing need to error on cycles). ``` // Causes `db.query()` to actually return `Result<V, CycleError>` fn query(&self, key: K, key2: K2) -> V; ``` A proper implementation of this would likely return `Result<V, CycleError<(K, K2)>>` or maybe larger changes are needed. cc #6
30 lines
786 B
Rust
30 lines
786 B
Rust
use crate::setup::{ParDatabase, ParDatabaseImpl};
|
|
use salsa::ParallelDatabase;
|
|
|
|
/// Test two `sum` queries (on distinct keys) executing in different
|
|
/// threads. Really just a test that `snapshot` etc compiles.
|
|
#[test]
|
|
fn in_par_two_independent_queries() {
|
|
let mut db = ParDatabaseImpl::default();
|
|
|
|
db.set_input('a', 100);
|
|
db.set_input('b', 010);
|
|
db.set_input('c', 001);
|
|
db.set_input('d', 200);
|
|
db.set_input('e', 020);
|
|
db.set_input('f', 002);
|
|
|
|
let thread1 = std::thread::spawn({
|
|
let db = db.snapshot();
|
|
move || db.sum("abc")
|
|
});
|
|
|
|
let thread2 = std::thread::spawn({
|
|
let db = db.snapshot();
|
|
move || db.sum("def")
|
|
});
|
|
|
|
assert_eq!(thread1.join().unwrap(), 111);
|
|
assert_eq!(thread2.join().unwrap(), 222);
|
|
}
|