Ví Dụ Đơn Giản
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 | func leak() { doWork := func(strings <-chan string) <-chan interface{} { completed := make(chan interface{}) go func() { defer fmt.Println("doWork exited.") defer close(completed) for s := range strings { // Do something interesting fmt.Println(s) } }() fmt.Println("end function doWork") return completed } fmt.Println("dowork") doWork(nil) // Perhaps more work is done here fmt.Println("Done.") } |
- trong func doWork với parameter là một chan string.
- func sẽ leak vì string channel là một giá trị nil. Có nghĩa là goroutine này không clear tài nguyên, không stop func.
- ví dụ trên có lẽ là cực kì ngắn, nhưng trong thực tế thì func sẽ tồn tại trong lifetime và ảnh hưởng đến tài nguyên của chương trình.
Debug Resource
Cài package
- cài package:
apt-get install graphviz gv(debian) orbrew install graphviz(mac) - cài pprof:
go get -u github.com/google/pprof - import pprof:
import _ "net/http/pprof" - add server:
pprof
source
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 | package main import ( "fmt" "net/http" _ "net/http/pprof" "os" "os/signal" "syscall" ) func leak() { doWork := func(strings <-chan string) <-chan interface{} { completed := make(chan interface{}) go func() { defer func() { fmt.Println("doWork exited.") }() defer func() { close(completed) }() for s := range strings { // Do something interesting fmt.Println(s) } }() fmt.Println("end function doWork") return completed } fmt.Println("dowork") doWork(nil) // Perhaps more work is done here fmt.Println("Done.") } func main() { leak() leak() leak() go func() { http.ListenAndServe(":1234", nil) }() // sigs := make(chan os.Signal, 1) signal.Notify(sigs, syscall.SIGINT, syscall.SIGTERM) done := make(chan bool, 1) go func() { <-sigs done <- true }() <-done } |
- trong func main, gọi 3 hàm leak() -> trong lifetime sẽ có 3 goroutine bị leak
- start server với port 1234
- sau khi start server, mở một terminal khác
go tool pprof http://localhost:1234/debug/pprof/goroutinevà enterpng - sẽ có kết quả
Generating report in profile001.png
- Kết quả trong hình sử dụng pprof thì sẽ có 3 leak.
Video
https://www.youtube.com/watch?v=e1Aa4d90nzk
Source
https://github.com/ducnpdev/open-dev/blob/master/concurrency/leak.go