并发处理是 golang 应用程序的重要功能，本文介绍了 golang 框架中的基本并发技术，包括：goroutine：轻量级线程，使用 go 关键字启动。通道（channel）：安全地在 goroutine 之间通信，使用 make(chan ) 创建。mutex：锁机制，使用 sync.mutex 类型的 mutex。waitgroup：等待一组 goroutine 完成，使用 sync.waitgroup 类型的 waitgroup。实战案例：使用 goroutine 和通道并行处理 http 请求，通过 wait group 确保所有请求处理完毕后再退出主程序。
GoLang 框架中的并发处理技巧
简介
并发性是现代 GoLang 应用程序的关键功能，它允许程序同时执行多个任务，从而提升效率和响应能力。在本文中，我们将探讨 GoLang 框架中并发处理的基本技术，并提供一个实战案例。
立即学习“go语言免费学习笔记（深入）”；
Goroutine
Goroutine 是 GoLang 中的轻量级线程，可用于并发执行代码。使用 go 关键字启动 Goroutine：
go func() {
// Goroutine 中的代码
}()
通道（Channel）
通道是一个用于在 Goroutine 之间安全通信的数据结构。通道的类型定义为 chan ，其中 是通道传输的数据类型。
// 创建一个整型通道 c := make(chan int) // 发送数据到通道 c <- 10 // 从通道接收数据 value := <-c
Mutex
Mutex 是一种锁机制，用于防止对共享资源的并发访问。在 GoLang 中，使用 sync.Mutex 类型实现 Mutex。
// 创建一个 Mutex var m sync.Mutex // 获取 Mutex 锁 m.Lock() // 释放 Mutex 锁 m.Unlock()
WaitGroup
WaitGroup 用于等待一组 Goroutine 完成。WaitGroup 的 Add 方法指定 Goroutine 的数量，Wait 方法阻塞，直到所有 Goroutine 完成。
// 创建一个 WaitGroup var wg sync.WaitGroup // 添加一个 Goroutine wg.Add(1) // 当 Goroutine 执行完毕后，调用 Done 完成计数 wg.Done() // 等待所有 Goroutine 完成 wg.Wait()
实战案例
让我们考虑一个使用 Goroutine 和通道并行处理大量请求的 HTTP 服务器。
package main
import (
"net/http"
"time"
"fmt"
"sync"
)
var wg sync.WaitGroup
func main() {
// 创建一个通道来接收请求
requests := make(chan *http.Request)
// 创建一个 Goroutine 池来处理请求
for i := 0; i < 10; i++ {
go func() {
for request := range requests {
// 模拟处理请求
time.Sleep(50 * time.Millisecond)
fmt.Println("处理请求:", request.URL.Path)
wg.Done()
}
}()
}
// 启动 HTTP 服务器
http.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) {
// 将请求发送到 Goroutine 池
requests <- r
// 等待所有请求处理完毕
wg.Wait()
})
http.ListenAndServe(":8080", nil)
}
在这个示例中，HTTP 请求通过通道发送到 Goroutine 池，并在 Goroutine 中并行处理。使用 WaitGroup 确保在所有请求处理完毕之前主 Goroutine 不退出。
