30 lines
780 B
Rust
30 lines
780 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', 10);
|
||
|
|
db.set_input('c', 1);
|
||
|
|
db.set_input('d', 200);
|
||
|
|
db.set_input('e', 20);
|
||
|
|
db.set_input('f', 2);
|
||
|
|
|
||
|
|
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);
|
||
|
|
}
|