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

The Go Programming Language

Go Projects

This topic created in 1593 days ago, the information mentioned may be changed or developed.

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
}

Supplement 1 · Dec 30, 2021

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

18 replies • 2022-01-10 06:51:32 +08:00

iyear

Dec 30, 2021 via Android

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

wangdashuai

Dec 30, 2021

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

CEBBCAT

Dec 30, 2021 via Android

queryAll 中的协程加上 select

keepeye

Dec 30, 2021

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

vizee

Dec 30, 2021

ch := make(chan int, 3)

脑筋急转弯是吧

gamexg

Dec 30, 2021

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

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

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

gamexg

Dec 30, 2021

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

xiaoFine

Dec 30, 2021

小白一问，试了下诸君的方法，并不行啊
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

Dec 30, 2021

目前能想到的只能是这样(不改变签名），有更优雅的方法吗。。
```
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
**/
```