Function test_concurrent_reads

atomic-core/src/change/store.rs:982–1006

()

    #[test]
    fn test_concurrent_reads() {
        use std::sync::Arc;
        use std::thread;

        let store = Arc::new(MemoryChangeStore::new());
        let change = create_test_change("Concurrent", b"shared data");
        let hash = change.hash().unwrap();
        store.insert(hash, change);

        let handles: Vec<_> = (0..4)
            .map(|_| {
                let store = Arc::clone(&store);
                thread::spawn(move || {
                    for _ in 0..100 {
                        assert!(store.has_change(&hash));
                        let _ = store.get_change(&hash).unwrap();
                    }
                })
            })
            .collect();

        for handle in handles {
            handle.join().unwrap();
        }
    }

    // ------------------------------------------------------------------------
    // Edge Case Tests