如何在 Golang 中使用通道处理错误？

package main

import (

“errors”

“fmt”

“sync”

)

// 一个产生整数的出错通道

var errorChannel = make(chan Result, 100)

// 模拟 goroutine 产生错误

var generateErr = func() (int, error) {

if random.Bool() {

return 软件开发定制mhkj33random.Int(), nil

}

// 注入一个错误的模拟

return 0, errors.New(“模拟错误”)

}

// Goroutine 同时处理错误

var resultHandler = func() {

var wg sync.WaitGroup

for {

result, ok := <-errorChannel

if !ok {

// 通道已关闭，停止 goroutine

break

}

wg.Add(1)

go func(r Result) {

defer wg.Done()

// 处理结果或错误

if r.Err != nil {

fmt.Printf(“发现错误: %s\n”, r.Err)

} el软件开发定制mhkj33se {

fmt.Printf(“收到结果: %d\n”, r.Value)

}

}(result)

}

wg.Wait()

}

// 模拟在 goroutine 中并发传递数据

var simulateAsync = func() {

// 向 errorChannel 发送数据

for i := 0; i < 100; i++ {

result, err := generateErr()

errorChannel <- Result{Value: result, Err: err}

}

close(errorChannel)

// 等待容错 goroutine 完成

resultHandler()

}

登录后复制

go 软件开发定制mhkj33run main.go

登录后复制

发现错误: 模拟错误

收到结果: 2343

收到结果: 678

发现错误: 模拟错误

…

登录后复制