当前位置：首页 > news >正文

Go 踩过的坑之协程参数不能过大

news 2025/8/9 8:40:37

文章目录

- 一、问题
- 二、原因
- 三、解决：
- 四、修改：
- 五、总结

一、问题

在日常开发过程中，我们通常会使用协程来并发处理数据，比如下面的例子采用协程 + sync.WaitGroup 来并发处理数据：

从mysql请求的切片数据，遍历后开启协程根据指定字段统计数据，此处采用了协程组的方式提高效率

代码如下：

//结构体
type RespStruct struct{struct01 //内嵌另外的结构体struct02 //内嵌另外的结构体
}
func StatisticData(){var respData []RespStructvar wg sync.WaitGroup//1.从mysql查询数据，封装到respData ，代码省略//2.循环respData并且开启协程组,添加协程for i, d := range respData {wg.Add(1)go func(req ProduceOrderProcessQueryRespParam) {defer func() {wg.Done()}()//打印参数fmt.Println(req)return}(d)}wg.wait()fmt.Println("end.....")
}

输出报错:

fatal error: newproc: function arguments too large for new goroutine

二、原因

由于结构体嵌结构体，变成新的比较大的结构体d。那么在启动新协程的时候，又因为是值传递，新copy了一份d的副本，导致参数超过了新goroutine的可用堆栈空间。 goroutine默认分配2k的内存

三、解决：

1.改为指针类型传递（推荐）
2.减少传递参数的大小，只传入需要使用的参数（推荐）
3.去除协程

四、修改：

将协程的匿名函数修改为函数调用方式；代码修改如下

//结构体
type RespStruct struct{struct01 //内嵌另外的结构体struct02 //内嵌另外的结构体
}
func StatisticData(){var respData []RespStructvar wg sync.WaitGroup//1.从mysql查询数据，封装到respData ，代码省略//2.循环respData并且开启协程组,添加协程for i, d := range respData {wg.Add(1)go func(req *ProduceOrderProcessQueryRespParam) {defer func() {wg.Done()}()//打印参数fmt.Println(req)return}(&d)}wg.wait()fmt.Println("end.....")
}