go并发小工具errgroup

Posted 2022-12-07 柳清风09

先看demo

package main

import (
	"fmt"
	"golang.org/x/sync/errgroup"
	"net/http"
)

func main() 
	var g errgroup.Group
	var urls = []string
		"http://www.golang.org/",
		"http://www.xxxzzzzzzxxxx.com",
		"http://www.google.com/",
	
	for i := range urls 
		url := urls[i]
		g.Go(func() error 
			resp, err := http.Get(url)
			if err == nil 
				resp.Body.Close()
			
			fmt.Println(url)
			return err
		)
	
	if err := g.Wait(); err != nil 
		fmt.Printf("error %v", err)
		return
	
	fmt.Println("Successfully fetched all URLs.")

这里有个小问题大家需要注意，g.Wait 返回的只有一个错误，也就是指返回第一个错误，如果请求中有多个报错将会被忽略。
所以如果你需要获取每个报错，我还是建议你使用 waitgroup的方式。