Function mustFinishCore

core/runner_test.go:15–24

(t *testing.T, d time.Duration, msg string, fn func())

)

func mustFinishCore(t *testing.T, d time.Duration, msg string, fn func()) {
	t.Helper()
	done := make(chan struct{})
	go func() { fn(); close(done) }()
	select {
	case <-done:
	case <-time.After(d):
		t.Fatalf("timeout: %s", msg)
	}
}

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