Golang极简入门教程(三):并发支持

2019-11-10 09:01:54王旭

Golang 运行时(runtime)管理了一种轻量级线程,被叫做 goroutine。创建数十万级的 goroutine 是没有问题的。范例:


package main
 
import (
    "fmt"
    "time"
)
 
func say(s string) {
    for i := 0; i < 5; i++ {
        time.Sleep(100 * time.Millisecond)
        fmt.Println(s)
    }
}
 
func main() {
    // 开启一个 goroutine 执行 say 函数
    go say("world")
    say("hello")
}

我们使用 channel 和 goroutine 通讯。channel 中是一种带有类型的通道,被用于接收和发送特定类型的值。操作符 <- 被叫做 channel 操作符(这个操作符中箭头表明了值的流向):


// 发送 v 到 channel ch
ch <- v
// 接收 channel ch 中的值并赋值给 v
v := <-ch

使用 channel 和 goroutine 通讯能够避免显式使用锁机制,通过 channel 发送和接收值时默认是阻塞的。

通过 make 函数创建 channel:


// int 指定 channel 收发值的类型为 int
ch := make(chan int)

一个完整的例子:


package main
 
import "fmt"
 
// 计算数组 a 中所有元素值之和
func sum(a []int, c chan int) {
    sum := 0
    for _, v := range a {
        sum += v
    }
    // 计算结果发送到 channel c
    c <- sum
}
 
func main() {
    a := []int{7, 2, 8, -9, 4, 0}
 
    // 创建 channel c
    c := make(chan int)
 
    go sum(a[:len(a)/2], c)
    go sum(a[len(a)/2:], c)
 
    // 接收两个 goroutine 发送的计算结果
    x, y := <-c, <-c
 
    fmt.Println(x, y, x+y)
}package main
 
import "fmt"
 
// 计算数组 a 中所有元素值之和
func sum(a []int, c chan int) {
    sum := 0
    for _, v := range a {
        sum += v
    }
    // 计算结果发送到 channel c
    c <- sum
}
 
func main() {
    a := []int{7, 2, 8, -9, 4, 0}
 
    // 创建 channel c
    c := make(chan int)
 
    go sum(a[:len(a)/2], c)