第5章—并发控制Channel

文章预览

来自《Go 专家编程》——任洪彩
我们考虑这么一种场景，协程A在执行过程中需要创建子协程A1、A2、A3...An,协程A创建完子协程后就等待子协程退出。针对这种场景，Go提供了三种解决方案。
1、Channel:使用channel控制子协程——实现简单，清晰易懂,但是需要大量创建协程时就需要有相同数量的channel,而且对于子协程继续派生出的协程不方便控制。
2、WaitGroup:使用信号量机制控制子协程——子协程个数可动态调整
3、Context:使用上下文控制子协程——对子协程派生出来的孙子协程的控制
channel一般用于协程的通信，也可以用于并发控制。比如主协程启动N个子协程，主协程等待所有子协程退出后再继续后续流程，这种场景下channel也可以轻易实现并发控制。

package main

import (
    "fmt"
    "time"
)

func Process(ch chan int) {
    time.Sleep(time.Second)
    ch <- 1 //在管道中写入一个元素表示当前协程已结束
}

func main() {
    channels := make([]chan int, 10)
    for i := 0; i < 10; i++ {
        channels[i] = make(chan int) //在切片中放入一个channel
        go Process(channels[i])
    }
    for i, ch := range channels { //遍历切片
        <-ch //等待子协程结束,也可以向管道中写入数据通知子协程结束，这时候子协程需要定期地探测管道中是否有消息出现
        fmt.Println("Routine ", i, " quit!")
    }

}

………………………………