🔐 第12课:sync包

并发编程 第2阶段·第5/7课

📋 本课目标

🔬 代码演示与验证

package main
import ("fmt";"sync";"sync/atomic")
func main() {
    fmt.Println("=== Mutex ===")
    var mu sync.Mutex;counter:=0;var wg1 sync.WaitGroup
    for i:=0;i<1000;i++{wg1.Add(1);go func(){defer wg1.Done();mu.Lock();counter++;mu.Unlock()}()}
    wg1.Wait();fmt.Printf("加锁:%d\n",counter)
    fmt.Println("\n=== RWMutex ===")
    var rwmu sync.RWMutex;data:=map[string]int{"go":2009};var wg2 sync.WaitGroup
    for i:=0;i<3;i++{wg2.Add(1);go func(id int){defer wg2.Done();rwmu.RLock();fmt.Printf("  读者%d:%d\n",id,data["go"]);rwmu.RUnlock()}(i)}
    wg2.Wait()
    fmt.Println("\n=== WaitGroup ===")
    var wg sync.WaitGroup;for i:=0;i<5;i++{wg.Add(1);go func(id int){defer wg.Done();fmt.Printf("  任务%d\n",id)}(i)};wg.Wait()
    fmt.Println("\n=== Once ===")
    var once sync.Once;for i:=0;i<5;i++{once.Do(func(){fmt.Println("  只一次!")})}
    fmt.Println("\n=== atomic ===")
    var count int64;var wg3 sync.WaitGroup
    for i:=0;i<1000;i++{wg3.Add(1);go func(){defer wg3.Done();atomic.AddInt64(&count,1)}()}
    wg3.Wait();fmt.Printf("原子:%d\n",atomic.LoadInt64(&count))
    fmt.Println("\n=== sync.Map ===")
    var m sync.Map;m.Store("name","Go")
    if v,ok:=m.Load("name");ok{fmt.Printf("  name:%v\n",v)}
}

🔍 运行验证

✅ 验证通过 — 实机运行结果:

=== Mutex ===
加锁:1000

=== RWMutex ===
  读者2:2009
  读者0:2009
  读者1:2009

=== WaitGroup ===
  任务4
  任务0
  任务2
  任务1
  任务3

=== Once ===
  只一次!

=== atomic ===
原子:1000

=== sync.Map ===
  name:Go

🧠 sync原语

Mutex: 互斥锁 | RWMutex: 读写锁 WaitGroup: 等待组 | Once: 单次执行 atomic: 原子操作 | sync.Map: 并发map

🔐 Mutex

mu.Lock(); defer mu.Unlock()
// ❌ 忘记解锁 → 死锁
// ❌ 重复加锁 → 死锁
// ✅ defer保证释放

🔑 本课要点回顾

知识点关键内容
MutexLock/Unlock/defer
RWMutexRLock/RUnlock读共享
WaitGroupAdd/Done/Wait
OnceDo单次执行
atomicAdd/Load/Store/CAS

🏋️ 练习

安全计数

Mutex vs atomic

并发缓存

RWMutex CRUD

单例

sync.Once DB连接

🏆

成就解锁:同步守护者!

📖 延伸阅读

🎯 实战建议

  1. 动手编写代码,不要只看不练
  2. 使用go doc查看标准库文档
  3. 编写测试用例验证理解
  4. 阅读优秀开源项目的源码
  5. 在项目中应用所学知识

⚡ 性能提示

// 1. 预分配切片容量
s := make([]int, 0, expectedSize)

// 2. 使用strings.Builder拼接
var b strings.Builder
b.WriteString("hello")

// 3. 对象池复用
var bufPool = sync.Pool{New: func() interface{} { return new(bytes.Buffer) }}

// 4. 减少逃逸分析
// 小对象栈分配,大对象堆分配

// 5. benchmark测试
func BenchmarkXxx(b *testing.B) {
    for i := 0; i < b.N; i++ { ... }
}

🔍 调试技巧

// 1. fmt.Printf格式化
fmt.Printf("%+v
", struct)  // 带字段名
fmt.Printf("%#v
", value)   // Go语法

// 2. log包
log.Printf("debug: value=%v", val)

// 3. delve调试器
// dlv debug ./main.go

// 4. pprof性能分析
import _ "net/http/pprof"
go http.ListenAndServe(":6060", nil)

📖 延伸阅读与资源

🎯 实战开发建议

  1. 动手编码 — 只看不练等于没学,每课代码必须自己敲一遍
  2. 使用go docgo doc fmt.Printf 查看标准库文档
  3. 编写测试go test 验证你的理解是否正确
  4. 阅读源码 — 标准库是Go最佳实践的活教材
  5. 项目实战 — 在真实项目中应用所学

⚡ Go性能优化清单

// 1. 预分配切片容量 — 避免频繁扩容
s := make([]int, 0, expectedSize)

// 2. strings.Builder拼接 — 比fmt.Sprintf快3-5倍
var b strings.Builder
b.WriteString("hello")
b.WriteString(" world")
result := b.String()

// 3. sync.Pool对象复用 — 减少GC压力
var bufPool = sync.Pool{
    New: func() interface{} { return new(bytes.Buffer) },
}
buf := bufPool.Get().(*bytes.Buffer)
defer bufPool.Put(buf)

// 4. 减少堆分配 — 小对象栈分配,避免逃逸
// 用 go build -gcflags="-m" 分析逃逸

// 5. 使用benchmark验证性能
func BenchmarkXxx(b *testing.B) {
    for i := 0; i < b.N; i++ {
        // 被测代码
    }
}
// go test -bench=. -benchmem

🔍 调试与排查技巧

// 1. 格式化调试输出
fmt.Printf("%+v
", myStruct)  // 带字段名
fmt.Printf("%#v
", myValue)   // Go语法表示

// 2. log包运行时日志
log.Printf("[DEBUG] value=%v", val)
log.SetFlags(log.LstdFlags | log.Lshortfile)

// 3. delve源码调试器
// 安装: go install github.com/go-delve/delve/cmd/dlv@latest
// 使用: dlv debug ./main.go
// 命令: break main.main / continue / next / print

// 4. pprof性能分析
import _ "net/http/pprof"
go http.ListenAndServe(":6060", nil)
// 访问: http://localhost:6060/debug/pprof/
// 命令: go tool pprof http://localhost:6060/debug/pprof/profile

// 5. race detector竞态检测
// go run -race main.go
// go test -race ./...

📊 Go工具生态

工具用途安装
golangci-lint代码静态检查go install github.com/golangci/golangci-lint/cmd/...@latest
gofumpt代码格式化(增强)go install mvdan.cc/gofumpt@latest
goimports自动管理importgo install golang.org/x/tools/cmd/goimports@latest
dlv源码调试器go install github.com/go-delve/delve/cmd/dlv@latest
air热重载开发go install github.com/cosmtrek/air@latest
swagSwagger文档生成go install github.com/swaggo/swag/cmd/swag@latest
migrate数据库迁移go install -tags 'postgres' github.com/golang-migrate/migrate/v4/cmd/migrate@latest

🏗️ Go项目结构最佳实践

myproject/
├── cmd/                    # 可执行程序入口
│   └── server/
│       └── main.go
├── internal/               # 私有代码(不可外部导入)
│   ├── handler/            # HTTP处理
│   ├── service/            # 业务逻辑
│   ├── repository/         # 数据访问
│   └── model/              # 数据模型
├── pkg/                    # 可复用公共包
│   └── utils/
├── api/                    # API定义(proto/openapi)
├── configs/                # 配置文件
├── scripts/                # 构建/部署脚本
├── test/                   # 集成测试
├── go.mod
├── go.sum
├── Makefile
└── Dockerfile

🌐 Go Web开发生态

类别推荐方案替代方案
Web框架GinEcho / Chi / Fiber
ORMGORMEnt / sqlx / sqlc
配置Viperkoanf
日志zapzerolog / slog
验证validatorgo-playground/validator
缓存go-redisredigo
JWTgolang-jwt
Swaggerswag
测试testify
Mockgomocktestify/mock

💡 编码规范

// 命名规范
// 包名: 小写单词, 不用下划线  package httputil
// 导出: 大写开头              func CreateUser()
// 未导出: 小写开头            func validateInput()
// 接口: -er后缀              type Reader interface{}
// 常量: 驼峰                 const maxRetries = 3
// 枚举: 类型+常量            type Role int; const Admin Role = 0

// 错误处理规范
// 错误变量: Err前缀           var ErrNotFound = errors.New("...")
// 错误类型: Error后缀         type ValidationError struct{...}
// 包装: %w                    fmt.Errorf("查询失败: %w", err)

// 注释规范
// 导出符号必须有注释
// 注释以符号名开头            // CreateUser creates a new user.
// 包注释: doc.go              // Package user handles user operations.

🔐 安全编码要点

// 1. 输入验证 — 永远不信任用户输入
// 2. SQL注入 — 使用参数化查询
db.Query("SELECT * FROM users WHERE id = $1", id)  // ✅
db.Query("SELECT * FROM users WHERE id = " + id)    // ❌

// 3. XSS防护 — HTML转义
template.HTML(escape(userInput))  // 或使用html/template自动转义

// 4. CSRF — 使用token验证
// 5. 密码 — bcrypt/argon2哈希, 永不明文存储
hashed, _ := bcrypt.GenerateFromPassword([]byte(pwd), bcrypt.DefaultCost)

// 6. HTTPS — 生产环境必须
// 7. 日志脱敏 — 不记录密码/Token
log.Printf("user login: id=%d", userID)  // ✅
log.Printf("password=%s", pwd)            // ❌

📦 依赖管理规范

// go.mod最佳实践
module github.com/yourorg/yourproject

go 1.22

// 直接依赖 — 项目直接使用的包
require (
    github.com/gin-gonic/gin v1.9.1
    gorm.io/gorm v1.25.0
)

// 间接依赖 — 自动管理, 不要手动编辑
require (
    github.com/json-iterator/go v1.1.12 // indirect
)

// 替换 — 本地开发/ fork修复
replace github.com/original/pkg => ../local-fork

// 排除 — 排除有问题的版本
exclude github.com/broken/pkg v1.0.0