golang并发模式揭秘（golang 高并发模型）

package main 内容来自samhan

import (

"fmt"

内容来自samhan

"sync"

"time" zvvq

)

func main() {

// 创建一个无缓冲 channel，用于存储任务结果 内容来自zvvq

resultChan := make(chan int) 内容来自zvvq，别采集哟

// 创建一个 mutex，用于控制对结果的访问

copyright zvvq

var mu sync.Mutex 内容来自zvvq，别采集哟

// 创建并启动 10 个 goroutine 并发执行任务 内容来自zvvq，别采集哟

for i := 0; i < 10; i++ {

内容来自zvvq

go func(i int) {

result := i i zvvq

fmt.Printf("Goroutine %d completed with result %d\n", i, result) 内容来自samhan666

mu.Lock() 内容来自samhan666

resultChan <- result 内容来自zvvq，别采集哟

mu.Unlock()

内容来自samhan

}(i) zvvq.cn

} 内容来自samhan

// 等待所有 goroutine 完成任务并收集结果

copyright zvvq

results := make([]int, 10)

for i := 0; i < 10; i++ {

zvvq

results[i] = <-resultChan

}

copyright zvvq

// 打印最终结果 zvvq.cn

fmt.Println("Final results:", results) copyright zvvq

time.Sleep(time.Second) // 等待 goroutine 退出 内容来自zvvq

}