type Result struct {
    Data []string
    Err  error
}

resultCh := make(chan Result, 3)
<p>go func() {
data, err := fetchDataFromSourceA()
resultCh <- Result{Data: data, Err: err}
}()</p><p>go func() {
data, err := fetchDataFromSourceB()
resultCh <- Result{Data: data, Err: err}
}()</p><p>go func() {
data, err := fetchDataFromSourceC()
resultCh <- Result{Data: data, Err: err}
}()</p>

var aggregated []string
for i := 0; i < 3; i++ {
    result := <-resultCh
    if result.Err != nil {
        log.Printf("task failed: %v", result.Err)
        continue
    }
    aggregated = append(aggregated, result.Data...)
}

semaphore := make(chan struct{}, 10) // 最多 10 个并发
<p>var wg sync.WaitGroup
resultCh := make(chan Result, len(tasks))</p><p>for _, task := range tasks {
wg.Add(1)
go func(t Task) {
defer wg.Done()
semaphore <- struct{}{}        // 获取许可
defer func() { <-semaphore }() // 释放许可</p><pre class='brush:php;toolbar:false;'>    data, err := processTask(t)
    resultCh <- Result{Data: data, Err: err}
}(task)

}

本书是全面讲述PHP与MySQL的经典之作，书中不但全面介绍了两种技术的核心特性，还讲解了如何高效地结合这两种技术构建健壮的数据驱动的应用程序。本书涵盖了两种技术新版本中出现的最新特性，书中大量实际的示例和深入的分析均来自于作者在这方面多年的专业经验，可用于解决开发者在实际中所面临的各种挑战。

// 所有任务启动后关闭 resultCh go func() { wg.Wait() close(resultCh) }()

// 主协程收集结果 var aggregated []string for result := range resultCh { if result.Err == nil { aggregated = append(aggregated, result.Data...) } }

ctx, cancel := context.WithTimeout(context.Background(), 3*time.Second)
defer cancel()
<p>go func() {
time.Sleep(4 * time.Second) // 模拟慢请求
select {
case resultCh <- Result{Err: errors.New("timeout")}:
case <-ctx.Done():
}
}()</p>

select {
case result := <-resultCh:
    // 处理结果
case <-ctx.Done():
    return nil, ctx.Err()
}