Function RunConcurrentTest

pkg/tools/builtin/testutils.go:420–452

RunConcurrentTest 运行并发测试

(concurrency int, testFunc func() error)

// RunConcurrentTest 运行并发测试
func RunConcurrentTest(concurrency int, testFunc func() error) *ConcurrentTestResult {
	results := make(chan error, concurrency)

	start := time.Now()

	// 启动并发goroutines
	for range concurrency {
		go func() {
			results <- testFunc()
		}()
	}

	// 收集结果
	successCount := 0
	errorCount := 0
	var errors []error

	for range concurrency {
		if err := <-results; err != nil {
			errorCount++
			errors = append(errors, err)
		} else {
			successCount++
		}
	}

	return &ConcurrentTestResult{
		SuccessCount: successCount,
		ErrorCount:   errorCount,
		Errors:       errors,
		Duration:     time.Since(start),
	}
}

// SkipIfShort 如果是短测试模式则跳过
func SkipIfShort(t *testing.T) {