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,并找出切片中每个部分的最大值。这可以显著加快查找最大值的过程,尤其是当切片很大时。