极端情况下收缩 Go 进程的线程数
生活随笔
收集整理的這篇文章主要介紹了
极端情况下收缩 Go 进程的线程数
小編覺得挺不錯的,現在分享給大家,幫大家做個參考.
在 Go 的 runtime 里有一些創建了就沒法回收的東西。
之前在 這篇 里講過 allgs 沒法回收的問題。
除了 allgs 之外,當前 Go 創建的線程也是沒法退出的,比如這個來自 xiaorui.cc 的例子,我簡單做了個修改,能從網頁看到線程:
package?main/* #include?<stdio.h> #include?<stdlib.h> #include?<unistd.h> void?output(char?*str)?{usleep(1000000);printf("%s\n",?str); } */ import?"C" import?"unsafe"import?"net/http" import?_?"net/http/pprof"func?init()?{go?http.ListenAndServe(":9999",?nil) }func?main()?{for?i?:=?0;i?<?1000;i++?{go?func(){str?:=?"hello?cgo"//change?to?char*cstr?:=?C.CString(str)C.output(cstr)C.free(unsafe.Pointer(cstr))}()}select{} }可見 Goroutine 退出了,歷史上創建的線程也是不會退出的。之前我也一直認為沒有辦法退出這些線程,不過這周被同事教育,還是有辦法的。參考官方 issue 14592。文末有鏈接。?
雖然問題直到現在依然沒解決,但是這個 issue 里也提供了一種邪道解決辦法,直接調用 LockOSThread,而不調用 Unlock,這樣在退出的時候和當前 g 綁定的線程就會直接銷毀:
把開頭的程序改改,增加一個接口,killThread。
package?main/* #include?<stdio.h> #include?<stdlib.h> #include?<unistd.h> void?output(char?*str)?{usleep(1000000);printf("%s\n",?str); } */ import?"C"import?("net/http""unsafe""log"_?"net/http/pprof""runtime""sync" )func?init()?{go?http.ListenAndServe(":9999",?nil) }func?main()?{for?i?:=?0;?i?<?1000;?i++?{go?func()?{str?:=?"hello?cgo"//change?to?char*cstr?:=?C.CString(str)C.output(cstr)C.free(unsafe.Pointer(cstr))}()}killThreadService()select?{} }func?sayhello(wr?http.ResponseWriter,?r?*http.Request)?{KillOne() }func?killThreadService()?{http.HandleFunc("/",?sayhello)err?:=?http.ListenAndServe(":10003",?nil)if?err?!=?nil?{log.Fatal("ListenAndServe:",?err)} }//?KillOne?kills?a?thread func?KillOne()?{var?wg?sync.WaitGroupwg.Add(1)go?func()?{defer?wg.Done()runtime.LockOSThread()return}()wg.Wait() }啟動后,發現創建了 1k+ 線程,curl localhost:10003,可以發現線程數在逐漸降低。
[1] https://github.com/golang/go/issues/14592
總結
以上是生活随笔為你收集整理的极端情况下收缩 Go 进程的线程数的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: 在 Go 语言中 Patch 非导出函数
- 下一篇: packetdrill 简介