Function TestRunBatchConcurrent

pkg/evals/batch_test.go:87–121

TestRunBatchConcurrent 测试并发批量评估

(t *testing.T)

// TestRunBatchConcurrent 测试并发批量评估
func TestRunBatchConcurrent(t *testing.T) {
	mockProvider := &MockProvider{
		response: `{"score": 0.90, "reason": "并发测试"}`,
	}

	// 创建多个测试用例
	testCases := make([]*BatchTestCase, 10)
	for i := range 10 {
		testCases[i] = &BatchTestCase{
			ID: string(rune('A' + i)),
			Input: &TextEvalInput{
				Answer: "测试答案",
			},
		}
	}

	scorers := []Scorer{
		NewFaithfulnessScorer(mockProvider),
		NewHallucinationScorer(mockProvider),
	}

	// 测试并发度为 3
	result, err := RunBatchConcurrent(context.Background(), testCases, scorers, 3)
	if err != nil {
		t.Fatalf("RunBatchConcurrent() error = %v", err)
	}

	if len(result.Results) != 10 {
		t.Errorf("RunBatchConcurrent() got %d results, want 10", len(result.Results))
	}

	if result.Summary.SuccessfulCases != 10 {
		t.Errorf("RunBatchConcurrent() SuccessfulCases = %d, want 10", result.Summary.SuccessfulCases)
	}
}

// TestRunBatch_ProgressCallback 测试进度回调
func TestRunBatch_ProgressCallback(t *testing.T) {