并发处理是 golang 应用程序的重要功能,本文介绍了 golang 框架中的基本并发技术,包括:goroutine:轻量级线程,使用 go 关键字启动。通道(channel):安全地在 goroutine 之间通信,使用 make(chan
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 不退出。