在 go 函数并发编程中定位性能瓶颈的步骤：1. 定位 goroutine 泄漏（使用 runtime/debug.setmaxthreads 和 debug.printstack）；2. 识别 goroutine 阻塞（使用 runtime.setblockprofilerate 和 runtime/pprof）；3. 分析 goroutine 调度（使用 runtime/pprof）。
Go函数并发编程中性能瓶颈的定位
在Go中，并发编程通过Goroutine实现，它允许开发者编写并行代码，以充分利用多核CPU的优势。然而，当应用没有达到预期的性能时，找出瓶颈就变得至关重要。以下步骤可以帮助定位函数并发编程中的性能瓶颈：
1. 定位 goroutine 泄漏
Goroutine 泄漏是指忘记在不再需要时关闭 goroutine，导致程序中goroutine数量不断增加，从而造成内存和性能问题。使用 runtime/debug.SetMaxThreads 函数和 runtime/debug.PrintStack 函数可以监控 goroutine 数量并识别泄漏。
立即学习“go语言免费学习笔记（深入）”；
// 定位 goroutine 泄漏
package main
import (
"fmt"
"runtime"
"runtime/debug"
)
func main() {
// 实战案例：创建一个循环中持续创建 goroutine 的函数
createGoroutineLeak()
// 检查 goroutine 数量
fmt.Println("Current goroutine count:", runtime.NumGoroutine())
// 打印 goroutine 栈信息以调试泄漏
debug.PrintStack()
}
// 创建 goroutine 泄漏（模拟不关闭 goroutine）
func createGoroutineLeak() {
for {
go func() {
// 无限循环（模拟不关闭 goroutine）
for {}
}()
}
}2. 识别goroutine 阻塞
Goroutine 阻塞会阻止其他 goroutine 运行，从而导致性能下降。可以使用 runtime.SetBlockProfileRate 函数开启 goroutine 阻塞采样，并使用 runtime/pprof 包生成阻塞配置文件进行分析。
// 定位 goroutine 阻塞
package main
import (
"fmt"
"net/http/pprof"
"runtime"
)
func main() {
// 开启 goroutine 阻塞采样
runtime.SetBlockProfileRate(1)
// 实战案例：创建一个使用互斥锁死锁的函数
createGoroutineDeadlock()
// 生成本地阻塞配置文件
f, err := os.Create("goroutine-block.pprof")
if err != nil {
log.Fatal(err)
}
defer f.Close()
pprof.Lookup("block").WriteTo(f, 1)
fmt.Println("阻塞配置文件已生成：goroutine-block.pprof")
}
// 创建 goroutine 死锁（模拟互斥锁使用不当）
func createGoroutineDeadlock() {
var mu sync.Mutex
// goroutine 1 试图获取锁
go func() {
mu.Lock()
defer mu.Unlock()
// 无限循环（模拟死锁）
for {}
}()
// goroutine 2 试图获取锁
go func() {
mu.Lock()
defer mu.Unlock()
// 无限循环（模拟死锁）
for {}
}()
}3. 分析goroutine 调度
Goroutine 调度器负责将 goroutine 指派给可用的 CPU 核心。不当的调度策略可能会导致性能问题。可以使用 runtime/pprof 包生成 goroutine 调度配置文件进行分析。
// 分析 goroutine 调度
package main
import (
"fmt"
"net/http/pprof"
"runtime"
)
func main() {
// 生成本地 goroutine 调度配置文件
f, err := os.Create("goroutine-sched.pprof")
if err != nil {
log.Fatal(err)
}
defer f.Close()
pprof.Lookup("goroutine").WriteTo(f, 1)
fmt.Println("调度配置文件已生成：goroutine-sched.pprof")
} 
