go 中的协程是一种轻量级并发机制,允许在同一个进程中执行多个任务。它们共享进程内存空间,可以通过通道进行通信。此外,文章还提供了以下内容:协程创建使用 go 关键字。通道通过 make 函数创建,可用于在协程之间传递值。实战案例演示了如何使用协程实现并行计算,通过 8 个协程计算 10 万个素数。
Go 协程与并发模型
引言
协程是 Go 语言中一种轻量级的并发机制,允许在同一进程中运行多个独立的任务。本文将探讨 Go 中的协程和并发模型,并提供实战案例。
协程
协程是 Go 语言中的并发执行单元,与线程类似,但更加轻量级。协程共享同一个进程的内存空间,可以轻松地共享数据。创建协程使用 go 关键字,如下所示:
go func() { // 协程体 }
通道
通道是 Go 中的一种通信机制,用于在协程之间传递值。通道可以单向或双向,并且可以缓冲或无缓冲。创建通道使用 make 函数,如下所示:
ch := make(chan int, 10)
实践案例:并行计算
让我们使用协程实现并行计算的实战案例。我们创建一个协程池,并在每个协程中计算一个大素数表:
package main import ( "fmt" "math/rand" "time" ) const primeCount = 100000 // 计算素数 func isPrime(n int) bool { if n <= 1 { return false } for i := 2; i*i <= n; i++ { if n%i == 0 { return false } } return true } // 协程函数 func parallelPrimes(ch chan int) { for i := 0; i < primeCount; i++ { n := rand.Intn(100000) if isPrime(n) { ch <- n } } } func main() { // 创建通道和协程池 ch := make(chan int, primeCount) for i := 0; i < 8; i++ { go parallelPrimes(ch) } // 等待协程池完成 close(ch) start := time.Now() // 收集素数 for prime := range ch { fmt.Println(prime) } elapsed := time.Since(start) fmt.Printf("Elapsed time: %vn", elapsed) }
在这个案例中,我们创建了 8 个协程,每个协程负责计算 10 万个素数。主协程负责收集素数并将它们打印到控制台上。
以上就是Golang协程与并发模型的详细内容,更多请关注每日运维网(www.mryunwei.com)其它相关文章!