Go 使用channel控制并发

1. 前言

channel通常用于协程之间的通讯，channel也能够用于并发控制。好比主协程启动N个子协程，主协程等待全部子协程退出后再继续后续流程，这种场景下channel也可轻易实现。

2. 场景示例

下面程序展现一个使用channel控制子协程的例子：

package main

import (
    "time"
    "fmt"
)

func Process(ch chan int) {
    //Do some work...
    time.Sleep(time.Second)

    ch <- 1 //管道中写入一个元素表示当前协程已结束
}

func main() {
    channels := make([]chan int, 10) //建立一个10个元素的切片，元素类型为channel

    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!")
    }
}

上面程序经过建立N个channel来管理N个协程，每一个协程都有一个channel用于跟父协程通讯，父协程建立完全部协程中等待全部协程结束。

这个例子中，父协程仅仅是等待子协程结束，其实父协程也能够向管道中写入数据通知子协程结束，这时子协程须要按期的探测管道中是否有消息出现。

3. 总结

使用channel来控制子协程的优势是实现简单，缺点是当须要大量建立协程时就须要有相同数量的channel，并且对于子协程继续派生出来的协程不方便控制。

后面继续介绍的WaitGroup、Context看起来比channel优雅一些，在各类开源组件中使用频率比channel高得多。

赠人玫瑰手留余香，若是以为不错请给个赞~

本篇文章已归档到GitHub项目，求星~ 点我即达