Function TestRecordStat_ConcurrentSafety

core/runner_test.go:26–51

(t *testing.T)

}

func TestRecordStat_ConcurrentSafety(t *testing.T) {
	r := &Runner{}

	var wg sync.WaitGroup
	for i := 0; i < 100; i++ {
		wg.Add(1)
		go func(n int) {
			defer wg.Done()
			r.recordStat(&pkg.Statistor{
				Total:        n,
				ReqTotal:     int32(n * 2),
				FoundNumber:  1,
				FailedNumber: 0,
			})
		}(i)
	}

	mustFinishCore(t, 5*time.Second, "concurrent recordStat deadlocked", func() {
		wg.Wait()
	})

	stats := r.Stats()
	if stats.Requests == 0 {
		t.Fatal("stats.Requests should be > 0 after concurrent writes")
	}
}

func TestRecordStat_NilStat(t *testing.T) {
	r := &Runner{}