Method CheckDomainsWithProgress

internal/batch/manager.go:116–214

CheckDomainsWithProgress 带进度显示的并发批量检测

(ctx context.Context, domains []string)

// CheckDomainsWithProgress 带进度显示的并发批量检测
func (bm *Manager) CheckDomainsWithProgress(ctx context.Context, domains []string) ([]*types.DetectionResult, error) {
	results := make([]*types.DetectionResult, len(domains))
	resultChan := make(chan *ProgressResult, len(domains))

	// 启动并发检测
	go func() {
		defer close(resultChan)

		// 使用WaitGroup控制并发
		var wg sync.WaitGroup

		// 使用配置的最大并发数，提高检测效率
		concurrency := int(bm.config.Concurrency.MaxConcurrent) // 使用配置的并发数（默认8个）
		semaphore := make(chan struct{}, concurrency)

		for i, domain := range domains {
			wg.Add(1)
			go func(index int, domain string) {
				defer wg.Done()

				// 获取信号量
				select {
				case semaphore <- struct{}{}:
					defer func() {
						<-semaphore
					}()
				case <-ctx.Done():
					return
				}

				// 检测域名
				result, err := bm.engine.CheckDomain(ctx, domain)

				// 发送结果
				select {
				case resultChan <- &ProgressResult{
					Index:  index,
					Domain: domain,
					Result: result,
					Error:  err,
				}:
				case <-ctx.Done():
					return
				}
			}(i, domain)
		}

		wg.Wait()
	}()

	// 收集结果并显示进度
	completed := 0
	timeout := time.NewTimer(15 * time.Second) // 添加15秒总超时
	defer timeout.Stop()

	for completed < len(domains) {
		select {
		case progressResult := <-resultChan: