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)










