第六篇

本期看点（技巧类用【技】表示，易错点用【易】表示）：

（1）pprof查看运行时状态信息【技】

（2）goruntine使用后的销毁【易】

正文如下：

1 pprof查看运行时状态信息

pprof是Go语言的性能分析工具，主要可以分析以下几种情况：

• allocs：过去所有内存分配的示例
• block：导致同步原语阻塞的堆栈跟踪
• cmdline：当前程序的命令行调用
• goroutine：当前所有goroutine的堆栈跟踪
• heap：活动对象的内存分配示例。您可以指定gc GET参数，以便在执行堆样例之前运行gc。
• mutex：竞争互斥对象持有者的堆栈跟踪
• profile：CPU profile。可以在seconds GET参数中指定持续时间。获得概要文件后，使用go工具pprof命令来研究概要文件。
• threadcreate：用于创建新的操作系统线程的堆栈跟踪
• trace：当前程序执行的跟踪。可以在seconds GET参数中指定持续时间。获得跟踪文件后，使用go工具trace命令来调查跟踪。

运行代码：

package main

import (
   "fmt"
   "net/http"
   _ "net/http/pprof"
   "strings"
)

func main() {
   http.HandleFunc("/", func(writer http.ResponseWriter, request *http.Request) {
      writer.Write([]byte("Hello~"))
   })     
   http.ListenAndServe(":9090", nil) 
}

访问链接：http://localhost:9090/debug/pprof/

2 goruntine使用后的销毁

在上节我们学到了如何去控制goruntine的数量，因为短时间内大量的goroutine同时执行也会造成内存崩溃、CPU占用率过高等问题，不仅如此，当goruntine启动后未进行关闭时，因为大量的挤压goroutine也会造成相同的问题，因此我们要习惯在项目中使用goruntine后进行关闭。

2.1 使用后不销毁出现的问题示例

代码示例：

package main

import (
   "fmt"
   "net/http"
   _ "net/http/pprof"
)

func main() {
   ints := make(chan int,1000)
   i := 0

   worker := func (ch chan int){
      for v := range ch {
         fmt.Println(v)
      }
   }

   http.HandleFunc("/go", func(writer http.ResponseWriter, request *http.Request) {
      i+=1
      ints<-i
      go worker(ints)
   })
   http.ListenAndServe(":9090", nil)
}

查看pprof：

我们发现同一个地方我们只go出去一次，但是几次请求后还是有很多goruntine，这样如果大批量请求的话一定会出问题。

2.2 使用后销毁的方式

2.2.1 优化代码逻辑

第一种优化方式，就是换一种方式去监听channel：

package main

import (
   "fmt"
   "net/http"
   _ "net/http/pprof"
)


func main() {
   ints := make(chan int,1000)
   i := 0

   worker := func (ch chan int){
      select {
      case v := <-ch:
         fmt.Println(v)
      default:
         return
      }
   }

   http.HandleFunc("/go", func(writer http.ResponseWriter, request *http.Request) {
      i+=1
      ints<-i
      go worker(ints)
   })
   http.ListenAndServe(":9090", nil)
}

2.2.2 利用channel销毁多余的goruntine

第二种方式，我们可以close掉channel来间接的关闭监听他的goruntine

package main

import (
   "fmt"
   "net/http"
   _ "net/http/pprof"
)

func worker(v ...int) {
   count := len(v)
   res :=make(chan int,count)

   go func (ch chan int){
      for i := 0; i < count; i++ {
         fmt.Println(v[i])
         ch <- v[i]
      }
   }(res)

   for i := 0; i < count; i++ {
      <-res
   }

   close(res)
}

func main() {
   val := 0

   http.HandleFunc("/go", func(writer http.ResponseWriter, request *http.Request) {
      val += 1
      go worker(val)
   })
   http.ListenAndServe(":9090", nil)
}

2.2.3 利用Context销毁多余的goruntine

第三种方式，使用Context机制关闭多余的goruntine

转自：https://juejin.cn/post/7221151497974775865