golang 的并发模式利用以下原语：goroutine（轻量级并发执行单元）、channel（通信通道）、sync.mutex（互斥锁）。实战案例 使用这些原语并行执行任务，并使用无缓冲 channel 存储任务结果，使用 sync.mutex 保护对结果的并发访问，最终收集并打印结果。
Golang 并发模式揭秘
Golang 是一个高并发、高性能的编程语言，其内置的并发原语提供了强大的并发功能。本文将探讨 Golang 的并发模式，并通过实战案例 演示如何有效地管理并发。
并发模式
goroutine 是 Golang 的轻量级并发执行单元，可以并发执行不同的任务。go 关键字用于创建新的 goroutine。
channel 是通信通道，用于在 goroutine 之间传递数据。channel 通常是无缓冲或有缓冲的。
“go语言免费”；
sync.Mutex 用于互斥锁，防止并发访问共享数据。
实战案例
下面是一个使用 goroutine 和 channel 并发执行多个任务的示例：
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
package main
import (
"fmt"
"sync"
"time"
)
func main() {
// 创建一个无缓冲 channel，用于存储任务结果
resultChan := make(chan int)
// 创建一个 mutex，用于控制对结果的访问
var mu sync.Mutex
// 创建并启动 10 个 goroutine 并发执行任务
for i := 0; i < 10; i++ {
go func(i int) {
result := i i
fmt.Printf("Goroutine %d completed with result %d\n", i, result)
mu.Lock()
resultChan <- result
mu.Unlock()
}(i)
}
// 等待所有 goroutine 完成任务并收集结果
results := make([]int, 10)
for i := 0; i < 10; i++ {
results[i] = <-resultChan
}
// 打印最终结果
fmt.Println("Final results:", results)
time.Sleep(time.Second) // 等待 goroutine 退出
}
在这个示例中：
我们创建了一个无缓冲 channel resultChan 来存储任务结果。 我们使用 sync.Mutex 来保护对结果的并发访问。 我们创建了 10 个 goroutine，每个 goroutine 计算一个平方并将其发送到 resultChan。 主 goroutine 等待所有 goroutine 完成任务，收集并打印结果。该示例展示了如何使用 goroutine 和 channel 并发执行任务，如何保护共享数据，以及如何等待 goroutine 优雅退出。通过理解这些概念，您可以有效地管理并发并构建高性能的 Golang 应用程序。
以上就是golang并发模式揭秘的详细内容，更多请关注其它相关文章！