Go 优雅处理goroutines错误

在Go语言中，goroutines是轻量级的线程，它们在后台运行，可以并发执行任务。优雅地处理goroutines中的错误是确保程序稳定性和可维护性的关键。

使用Channel返回错误

Go中goroutines通常通过channel来通信。你可以创建一个额外的channel来发送错误信息。

案例一：

goroutines 中的通道理解为一种可以发射或接收信号的传感器。然后，我会将错误视为信号。当传感器收到信号（错误）时，它会通知我们已经收到信号，然后我们就可以利用这些信号启动进一步的流程。

package main

import (
	"errors"
	"fmt"
	"time"
)

func main() {
	errCh := make(chan error, 3)

	go errorSpawning(3*time.Second, errCh)
	go errorSpawning(2*time.Second, errCh)
	go errorSpawning(4*time.Second, errCh)

	for err := range errCh {
		if err != nil {
			panic(err)
		}
	}
}

func errorSpawning(delay time.Duration, errCh chan<- error) {
	time.Sleep(delay) //模拟业务处理时间
	fmt.Printf("业务运行%v后出现错误\n", delay)
	errCh <- errors.New("处理业务出错")
}

只需声明 errCh（错误通道），通道大小等于需要处理的 goroutines 数量。在本例中，errCh 的大小为 3。

然后将 errCh 作为 chan<- error 传递到函数中（该符号表示 errCh 在该函数中只是一个接收器）。再用一个 for 循环来捕捉错误信号，循环的 channel 为 errCh。

使用这种写法，如果有一个 goroutines 遇到错误，main() 函数就会崩溃。无需等待所有 goroutines 全部结束。

案例二：

package main

import (
	"errors"
	"fmt"
	"time"
)

func main() {
	errCh := make(chan error, 3)

	go errorSpawning(3*time.Second, errCh)
	go errorSpawning(2*time.Second, errCh)
	go errorSpawning(4*time.Second, errCh)

	for {
		select {
		case e := <-errCh:
			if e != nil {
				fmt.Println(e)
			}
		case <-time.After(time.Second * 5):
			return
		}
	}
}

func errorSpawning(delay time.Duration, errCh chan<- error) {
	defer func() {
		if r := recover(); r != nil {
			//...
		}
	}()

	time.Sleep(delay) //模拟业务处理时间
	err := errors.New("处理" + delay.String() + "的业务出错")
	errCh <- err

	if err != nil {
		panic(err)
	}
}

 一个goroutine错误不影响其他的goroutine