Golang 函数：并发任务执行中可扩展性和容错性的实现

package main

import (
    "fmt"
    "runtime"
)

func main() {
    // 并行执行 100 个 goroutine
    for i := 0; i < 100; i++ {
        go func(i int) {
            // 模拟耗时操作
            for j := 0; j < 1000000; j++ {}
            fmt.Println("Goroutine", i, "finished")
        }(i)
    }

    // 等待所有 goroutine 完成
    for {
        if runtime.NumGoroutine() == 1 {
            break
        }
    }
}

package main

import (
    "fmt"
    "sync"
)

func main() {
    var wg sync.WaitGroup

    // 并行执行 100 个任务，每个任务可能失败
    for i := 0; i < 100; i++ {
        wg.Add(1)
        go func(i int, errc chan error) {
            defer wg.Done()
            // 模拟任务执行
            if i%2 == 0 {
                errc <- fmt.Errorf("Task %d failed", i)
            }
        }(i, errc)
    }

    // 收集并处理错误
    errc := make(chan error)
    go func() {
        for err := range errc {
            fmt.Println(err)
        }
    }()

    // 等待所有任务完成
    wg.Wait()
    close(errc)
}