go 中 goroutine 的并行实现：goroutine 是轻量级并发执行体，由 go 调度器映射到操作系统线程上。调度器轮询 goroutine 队列并启动 goroutine。实战案例：并发查找切片中每个部分的最大值，显著加速查找速度。
Go 中 Goroutine 的并行实现
Go 中的 goroutine 是轻量级并发执行体，使程序员能够创建大量并发的任务而无需显式管理线程。
Goroutine 的实现
立即学习“go语言免费学习笔记（深入）”；
Go 调度器将 goroutine 映射到操作系统线程上。当创建一个新的 goroutine 时，它会被添加到调度器队列中。调度器轮询这个队列，并在可用处理器上启动 goroutine。这是通过内核处理程序来实现的，该内核处理程序负责线程调度。
实战案例
为了演示 Go 中 goroutine 的并行功能，我们创建一个程序来查找一个切片中的最大值。
package main
import (
"fmt"
"sync"
)
func main() {
// 创建一个切片并填充一些数字
nums := []int{1, 5, 2, 9, 3, 7, 4, 8, 6}
// 创建一个等待组来跟踪 goroutine 完成情况
var wg sync.WaitGroup
// 为每个数字创建 goroutine
for _, num := range nums {
wg.Add(1)
go findMax(num, &wg)
}
// 等待所有 goroutine 完成
wg.Wait()
}
// findMax 找出给定 goroutine 的最大值
func findMax(num int, wg *sync.WaitGroup) {
defer wg.Done() // 递减等待组计数器
// 获取当前最大的值
maxValue := num
for i := num + 1; i < len(nums); i++ {
if nums[i] > maxValue {
maxValue = nums[i]
}
}
// 打印最大值
fmt.Printf("Max value found by goroutine %v: %vn", num, maxValue)
}
在这个程序中，我们创建了一组 goroutine，每个 goroutine 都尝试找到切片中从其自身位置开始的最大值。使用等待组（sync.WaitGroup）来等待所有 goroutine 完成，从而确保在打印最大值之前所有 goroutine 都已完成。
此程序并行运行所有 goroutine，并找出切片中每个部分的最大值。这可以显著加快查找最大值的过程，尤其是当切片很大时。
