面试题：Go中Goroutine卡住对系统资源的影响及优化策略

Goroutine卡住对系统资源的影响

内存方面
- 内存泄漏：如果Goroutine持有大量不再使用但无法释放的资源（如打开的文件描述符、网络连接等），会导致内存无法回收，随着时间推移，系统内存被不断消耗，最终可能导致内存耗尽，引发系统OOM（Out - Of - Memory）错误。
- 内存膨胀：卡住的Goroutine可能持续申请内存，例如在循环中不断分配新的内存块而不释放，使得程序占用的内存不断增长，影响系统中其他进程的正常运行。
CPU方面
- CPU利用率升高：若Goroutine在一个无限循环且无阻塞操作（如for {}）中卡住，会一直占用CPU时间片，导致CPU利用率飙升，其他需要CPU资源的任务无法得到足够的计算资源，影响整个系统的性能。
- 调度开销增大：Go运行时的调度器需要不断尝试调度卡住的Goroutine，这会增加调度的开销，降低整体的调度效率。

优化策略

代码设计

设置合理的超时：

在进行网络请求、数据库查询等可能阻塞的操作时，设置合理的超时时间。例如，使用context包来控制Goroutine的生命周期和设置超时。

package main

import (
   "context"
   "fmt"
   "net/http"
   "time"
)

func main() {
   ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
   defer cancel()

   req, err := http.NewRequestWithContext(ctx, "GET", "http://example.com", nil)
   if err!= nil {
      fmt.Println("Error creating request:", err)
      return
   }

   client := &http.Client{}
   resp, err := client.Do(req)
   if err!= nil {
      fmt.Println("Error making request:", err)
      return
   }
   defer resp.Body.Close()
}

避免无限循环无阻塞：在循环中加入适当的阻塞操作，如使用time.Sleep或通道通信。例如，在一个需要周期性执行任务的Goroutine中：

package main

import (
   "fmt"
   "time"
)

func main() {
   go func() {
      for {
         fmt.Println("Doing some work")
         time.Sleep(1 * time.Second)
      }
   }()

   select {}
}

资源管理：确保Goroutine及时释放不再使用的资源。例如，在使用完文件、网络连接后，及时调用Close方法。

package main

import (
   "fmt"
   "os"
)

func main() {
   file, err := os.Open("test.txt")
   if err!= nil {
      fmt.Println("Error opening file:", err)
      return
   }
   defer file.Close()
}

通道缓冲与处理：合理设置通道的缓冲区大小，避免通道满或空导致的死锁。并且确保有足够的Goroutine来处理通道中的数据。例如：

package main

import (
   "fmt"
)

func main() {
   ch := make(chan int, 10)
   go func() {
      for i := 0; i < 20; i++ {
         ch <- i
      }
      close(ch)
   }()

   go func() {
      for val := range ch {
         fmt.Println(val)
      }
   }()

   select {}
}

运行时参数调整
- GOMAXPROCS：通过设置GOMAXPROCS环境变量或调用runtime.GOMAXPROCS函数来调整Go程序使用的CPU核心数。例如，在程序启动时：
```
package main

import (
   "fmt"
   "runtime"
)

func main() {
   runtime.GOMAXPROCS(2)
   fmt.Println("Using", runtime.GOMAXPROCS(0), "CPUs")
}
```
- 监控与调优工具：使用pprof工具来分析程序的性能，找出可能卡住的Goroutine。例如，在程序中加入如下代码：
```
package main

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

func main() {
   go func() {
      log.Println(http.ListenAndServe("localhost:6060", nil))
   }()

   // 程序主体逻辑
}
```
  然后通过浏览器访问http://localhost:6060/debug/pprof来查看程序的性能分析数据，包括CPU、内存使用情况等，进而发现和优化卡住的Goroutine。

星途面试题库

面试题：Go中Goroutine卡住对系统资源的影响及优化策略

知识考点

面试题答案

Goroutine卡住对系统资源的影响

优化策略