在 Go 语言中，SingleFlight 是 golang.org/x/sync/singleflight 包中的一个工具，旨在避免对同一资源或任务发起重复的请求。它的主要作用是合并多个相同的并发请求，使得这些请求只会执行一次，并且共享相同的结果，从而减少系统的负载，避免重复的工作。
SingleFlight 主要用于场景中，当多个 goroutine 发起对同一资源或任务的重复请求时，只会有一个请求被真正处理，其他请求会等待这个请求完成，并共享相同的结果。
Life is like a journey
SingleFlight 可以通过合并这些请求，只执行一次查询，其他请求则等待并返回相同的结果。SingleFlight 的工作原理SingleFlight 通过维护一个正在进行中的请求的集合来避免重复请求。SingleFlight 会把它们合并到一个请求上，只有一个请求会被真正执行。Do(key string, fn func() (interface{}, error)) (interface{}, error)：这个方法会执行给定的 fn 函数，但如果已经有一个相同 key 的请求正在执行，它会等待这个请求的结果，而不会重复执行函数。假设你有一个函数需要从外部服务获取数据，而多个并发请求可能会请求相同的数据。使用 SingleFlight 可以确保每个数据只请求一次，避免重复请求。
package main
import (
"fmt"
"log"
"sync"
"time"
"golang.org/x/sync/singleflight"
)
// 模拟一个耗时的操作（如查询数据库、外部API请求）
func fetchDataFromServer() (interface{}, error) {
// 模拟延时
time.Sleep(2 * time.Second)
return "Fetched Data", nil
}
func main() {
var g singleflight.Group
var wg sync.WaitGroup
// 模拟多个请求
for i := 0; i < 5; i++ {
wg.Add(1)
go func(i int) {
defer wg.Done()
// 使用 SingleFlight 合并相同的请求
result, err, _ := g.Do("uniqueKey", func() (interface{}, error) {
return fetchDataFromServer()
})
if err != nil {
log.Printf("Error fetching data: %v", err)
return
}
// 打印结果
fmt.Printf("Goroutine %d received result: %v\n", i, result)
}(i)
}
// 等待所有 goroutine 完成
wg.Wait()
}
fetchDataFromServer：模拟一个耗时的操作，可能是查询数据库或调用外部 API。singleflight.Group 来合并请求：每次调用 g.Do，都传入一个唯一的 key（这里是 "uniqueKey"）。对于相同的 key，如果有请求正在执行，其他请求会等待并复用该请求的结果。key），所以只有第一个请求会实际执行 fetchDataFromServer，其他请求会等待并共享该结果。fetchDataFromServer），后续的请求会等待第一次请求的结果。SingleFlight 的优势SingleFlight 的局限SingleFlight 可能会导致不必要的复杂性，反而影响性能。SingleFlight 是一个非常实用的工具，能够有效地避免对相同数据或资源的重复请求，合并多个相同的请求，使得多个并发请求可以共享一个计算或请求的结果。通过减少重复工作，它帮助提高了系统的性能，降低了负载。