这个 goroutine 泄露的 demo 如何修复？

V2EX = way to explore

V2EX 是一个关于分享和探索的地方

现在注册

已注册用户请登录

The Go Programming Language

› http://golang.org/

› Go Playground

Go Projects

› Revel Web Framework

这是一个创建于 1045 天前的主题，其中的信息可能已经有所发展或是发生改变。

func main() {
    for i := 0; i < 4; i++ {
        queryAll()
        fmt.Printf("goroutines: %d\n", runtime.NumGoroutine())
    }
}

func queryAll() int {
    ch := make(chan int)
    for i := 0; i < 3; i++ {
        go func() { ch <- query() }()
	    }
    return <-ch
}

func query() int {
    n := rand.Intn(100)
    time.Sleep(time.Duration(n) * time.Millisecond)
    return n
}

第 1 条附言 · 2021-12-30 19:31:28 +08:00

只是单纯讨论 goroutine 泄漏的一个 demo ，想从这个 demo 去学习如何分析泄露和修复的过程而已~

18 条回复 • 2022-01-10 06:51:32 +08:00

iyear

2021-12-30 09:55:41 +08:00 via Android

写三次，就读了一次当然剩下两个阻塞出不来了

wangdashuai

2021-12-30 10:04:52 +08:00

写个 woker 池处理，这样能保证 goroutine 数量不随任务增加。

CEBBCAT

2021-12-30 10:07:44 +08:00 via Android

queryAll 中的协程加上 select

keepeye

2021-12-30 10:10:31 +08:00

不知道这个例子的想实现什么功能，仅为了修复而修复的话，可以给 chan 加上 buffer 或者写的时候用 select 就不会阻塞了

vizee

2021-12-30 10:14:00 +08:00

ch := make(chan int, 3)

脑筋急转弯是吧

gamexg

2021-12-30 10:34:59 +08:00

如楼上，建立 3 缓冲区的 chan

或者写的时候检查是否已满。

select {
case ch <- query():
default:
}

gamexg

2021-12-30 10:43:12 +08:00

@gamexg #6 select 也要保证 chan 至少有 1 的缓冲区

xiaoFine

2021-12-30 11:01:04 +08:00

小白一问，试了下诸君的方法，并不行啊
1. buffer ch
```
func queryAll() int {
ch := make(chan int, 3)

for i := 0; i < 3; i++ {
go func() { ch <- query() }()
}
return <-ch
}
/**
goroutines: 3
goroutines: 5
goroutines: 5
goroutines: 7
**/
```
2. select
```
func queryAll() int {
ch := make(chan int, 3)

for i := 0; i < 3; i++ {
go func() {
select {
case ch <- query():
default:

}
}()
}
return <-ch
}
/**
goroutines: 3
goroutines: 5
goroutines: 5
goroutines: 7
**/
```

xiaoFine

2021-12-30 11:26:38 +08:00

目前能想到的只能是这样(不改变签名），有更优雅的方法吗。。
```
func queryAll() int {
ch := make(chan int)

for i := 0; i < 3; i++ {
go func() {ch <- query()}()
}
<-ch
<-ch
return <-ch
}
/**
goroutines: 1
goroutines: 1
goroutines: 1
goroutines: 1
**/
```