Function ScanWithConcurrency

scanner.go:196–218

ScanWithConcurrency 并发扫描

(hostChan <-chan Host, geo *Geo)

// ScanWithConcurrency 并发扫描
func ScanWithConcurrency(hostChan <-chan Host, geo *Geo) <-chan ScanResult {
	resultChan := make(chan ScanResult, 1000)
	
	// 使用sync.WaitGroup来等待所有工作协程完成
	var wg sync.WaitGroup
	
	// 启动工作协程
	for i := 0; i < config.Thread; i++ {
		wg.Add(1)
		go func() {
			defer wg.Done()
			BatchScan(hostChan, resultChan, geo)
		}()
	}
	
	// 启动一个协程来关闭结果通道
	go func() {
		wg.Wait() // 等待所有工作协程完成
		close(resultChan)
	}()
	
	return resultChan
}

// ValidateRealityTarget 验证Reality目标的完整性
func ValidateRealityTarget(result ScanResult) (bool, []string) {