Function TestPropertyConcurrentReadsSafe

property_test.go:1062–1097

--------------------------------------------------------------------------- Property: thread-safety — concurrent reads are panic-free and deterministic --------------------------------------------------------------------------- The parser must be safe for concurrent use (no shared mutable state). T

(t *testing.T)

// reqproof:proptest parser.Get
// Verifies: SYS-REQ-001 [property]
func TestPropertyConcurrentReadsSafe(t *testing.T) {
	r := newRNG(jsonSeed + 16)
	// Pre-generate a stable corpus so all goroutines share the same inputs.
	const corpus = 200
	inputs := make([][]byte, corpus)
	for i := range inputs {
		inputs[i] = randomJSONBytes(r, 2)
	}
	keys := []string{"a", "b", "c", "test", "name"}

	const goroutines = 16
	var wg sync.WaitGroup
	wg.Add(goroutines)
	errs := make(chan error, goroutines)
	for g := 0; g < goroutines; g++ {
		go func(seed int64) {
			defer wg.Done()
			gr := newRNG(seed)
			for i := 0; i < 500; i++ {
				raw := inputs[gr.Intn(corpus)]
				key := keys[gr.Intn(len(keys))]
				if !recoverNoPanic(func() {
					_, _, _, _ = Get(raw, key)
				}) {
					errs <- fmt.Errorf("Get panicked under concurrency on %q key=%q", raw, key)
					return
				}
			}
		}(jsonSeed + int64(g))
	}
	wg.Wait()
	close(errs)
	for e := range errs {
		t.Fatal(e)
	}
}

// closeEnough reports whether two floats agree to within a relative tolerance
// suitable for decimal round-trip comparisons.