通道

    通道的主要作用是用来实现并发同步。本篇文章将列出所有的和通道相关的概念、语法和规则。为了更好地理解通道，本文也对通道的可能的内部实现略加介绍。

    本篇文章中的信息量对于Go初学者来说可能有些密集。本文的某些段落可能需要反复阅读几遍才能有效吸收、消化和理解。

    Go语言设计团队的首任负责人Rob Pike对并发编程的一个建议是不要让计算通过共享内存来通讯，而应该让它们通过通讯来共享内存。通道机制就是这种哲学的一个设计结果。（在Go编程中，我们可以认为一个计算就是一个协程。）

    通过共享内存来通讯和通过通讯来共享内存是并发编程中的两种编程风格。当通过共享内存来通讯的时候，我们需要一些传统的并发同步技术（比如互斥锁）来避免数据竞争。

    Go提供了一种独特的并发同步技术来实现通过通讯来共享内存。此技术即为通道。我们可以把一个通道看作是在一个程序内部的一个先进先出（FIFO：first in first out）数据队列。一些协程可以向此通道发送数据，另外一些协程可以从此通道接收数据。

    随着一个数据值的传递（发送和接收），一些数据值的所有权从一个协程转移到了另一个协程。当一个协程发送一个值到一个通道，我们可以认为此协程释放了一些值的所有权。当一个协程从一个通道接收到一个值，我们可以认为此协程获取了一些值的所有权。

    当然，在通过通道传递数据的时候，也可能没有任何所有权发生转移。

    所有权发生转移的值常常被传递的值所引用着，但有时候也不并非如此。在Go中，和Rust语言不同，数据所有权的转移并非体现在语法上，而是体现在逻辑上。Go通道可以帮助程序员轻松地避免数据竞争，但不会绝对防止程序员犯错而写出糟烂的并发代码。

    尽管Go也支持几种传统的数据同步技术，但是只有通道为一等公民。通道是Go中的一种类型，所以我们可以无需引进任何代码包就可以使用通道。几种传统的数据同步技术提供在和sync/atomic标准库包中。

    实事求是地说，每种并发同步技术都有它们各自的最佳应用场景，但是通道的。使用通道来做同步常常可以使得代码看上去更整洁和易于理解。

    通道的一个问题是通道的编程体验常常很有趣以至于程序员们经常在并非是通道的最佳应用场景中仍坚持使用通道。

    通道类型和值

    和数组、切片以及映射类型一样，每个通道类型也有一个元素类型。一个通道只能传送它的（通道类型的）元素类型的值。 通道可以是双向的，也可以是单向的。

    • 字面形式chan T表示一个元素类型为T的双向通道类型。编译器允许从此类型的值中接收和向此类型的值中发送数据。
    • 字面形式chan<- T表示一个元素类型为T的单向发送通道类型。编译器不允许从此类型的值中接收数据。
    • 字面形式<-chan T表示一个元素类型为T的单向接收通道类型。编译器不允许向此类型的值中发送数据。 双向通道chan T的值可以被隐式转换为单向通道类型chan<- T和<-chan T，但反之不行（即使显式也不行）。类型chan<- T和<-chan T的值也不能相互转换。

    每个通道值有一个容量属性。此属性的意义将在下一节中得到解释。一个容量为0的通道值称为一个非缓冲通道（unbuffered channel），一个容量不为0的通道值称为一个缓冲通道（buffered channel）。

    通道类型的零值也使用预声明的nil来表示。一个非零通道值必须通过内置的make函数来创建。比如make(chan int, 10)将创建一个元素类型为int的通道值。第二个参数指定了欲创建的通道的容量。此第二个实参是可选的，它的默认值为0。

    通道值的比较

    所有通道类型均为可比较类型。

    从一文，我们了解到一个通道值可能含有底层部分。当一个通道值被赋给另一个通道值后，这两个通道值将共享相同的底层部分。换句话说，这两个通道引用着同一个底层的内部通道对象。比较这两个通道的结果为true。

    通道操作

    Go中有五种通道相关的操作。假设一个通道（值）为ch，下面列出了这五种操作的语法或者函数调用。

    • 调用内置函数close来关闭一个通道：

    传给close函数调用的实参必须为一个通道值，并且此通道值不能为单向接收的。

    • 使用下面的语法向通道ch发送一个值v：
    1. ch <- v
    • 使用下面的语法从通道ch接收一个值：
    1. <-ch

    如果一个通道操作不永久阻塞，它总会返回至少一个值，此值的类型为通道ch的元素类型。ch不能为单向发送通道。<-称为数据接收操作符，是的它和数据发送操作符的表示形式是一样的。

    在大多数场合下，一个数据接收操作可以被认为是一个单值表达式。但是，当一个数据接收操作被用做一个赋值语句中的唯一的源值的时候，它可以返回第二个可选的类型不确定的布尔值返回值从而成为一个多值表达式。此类型不确定的布尔值表示第一个接收到的值是否是在通道被关闭前发送的。（从后面的章节，我们将得知我们可以从一个已关闭的通道中接收到无穷个值。）

    数据接收操作在赋值中被用做源值的例子：

    1. v = <-ch
    2. v, sentBeforeClosed = <-ch
    • 查询一个通道的容量：
    1. cap(ch)

    其中cap是一个已经在容器类型一文中介绍过的内置函数。cap的返回值的类型为内置类型int。

    • 查询一个通道的长度：

    其中len是一个已经在一文中介绍过的内置函数。len的返回值的类型也为内置类型int。一个通道的长度是指当前有多少个已被发送到此通道但还未被接收出去的元素值。

    Go中大多数的基本操作都是未同步的。换句话说，它们都不是并发安全的。这些操作包括赋值、传参、和各种容器值操作等。但是，除了并发地关闭一个通道和向此通道发送数据这种情形，上面这些所有列出的操作都已经同步过了，因此它们可以在并发协程中安全运行而无需其它同步操作。我们在编程中应该避免并发地关闭一个通道和向此通道发送数据这种情形，因为这种情形属于不良设计（原因将在下面解释）。 !--https://github.com/golang/go/issues/30372https://github.com/golang/go/issues/27769-- 注意：通道的赋值和其它类型值的赋值一样，是未同步的。同样，将刚从一个通道接收出来的值赋给另一个值也是未同步的。

    如果被查询的通道为一个nil零值通道，则cap和len函数调用都返回0。这两个操作是如此简单，所以后面将不再对它们进行详解。事实上，这两个操作在实践中很少使用。

    通道的发送、接收和关闭操作将在下一节得到详细解释。

    为了让解释简单清楚，在本文后续部分，通道将被归为三类：

    • 零值（nil）通道；
    • 非零值但已关闭的通道；
    • 非零值并且尚未关闭的通道。 下表简单地描述了三种通道操作施加到三类通道的结果。

    对于上表中的五种未打上标的情形，规则很简单：

    • 关闭一个nil通道或者一个已经关闭的通道将产生一个恐慌。
    • 向一个已关闭的通道发送数据也将导致一个恐慌。
    • 向一个nil通道发送数据或者从一个nil通道接收数据将使当前协程永久阻塞。 下面将详细解释其它四种被打了上标（A/B/C/D）的情形。

    为了更好地理解通道和为了后续讲解方便，先了解一下通道类型的大致内部实现是很有帮助的。 我们可以认为一个通道内部维护了三个队列（均可被视为先进先出队列）：

    • 接收数据协程队列。此队列是一个没有长度限制的链表。此队列中的协程均处于阻塞状态，它们正等待着从此通道接收数据。
    • 发送数据协程队列。此队列也是一个没有长度限制的链表。此队列中的协程亦均处于阻塞状态，它们正等待着向此通道发送数据。此队列中的每个协程将要发送的值（或者此值的指针，取决于具体编译器实现）和此协程一起存储在此队列中。
    • 数据缓冲队列。这是一个循环队列，它的长度为此通道的容量。此队列中存放的值的类型都为此通道的元素类型。如果此队列中当前存放的值的个数已经达到此通道的容量，则我们说此通道已经处于满槽状态。如果此队列中当前存放的值的个数为零，则我们说此通道处于空槽状态。对于一个非缓冲通道（容量为零），它总是同时处于满槽状态和空槽状态。 每个通道内部维护着一个互斥锁用来在各种通道操作中防止数据竞争。 通道操作情形A：当一个协程Gr尝试从一个非零且尚未关闭的通道接收数据的时候，此协程Gr将首先尝试获取此通道的锁，成功之后将执行下列步骤，直到其中一个步骤的条件得到满足。
    • 如果此通道的缓冲队列不为空（这种情况下，接收数据协程队列必为空），此协程Gr将从缓冲队列取出接收一个值。如果发送数据协程队列不为空，一个发送协程将从此队列中弹出，此协程欲发送的值将被推入缓冲队列。此发送协程将恢复至运行状态。接收数据协程Gr继续运行，不会阻塞。对于这种情况，此数据接收操作为一个非阻塞操作。
    • 否则（即此通道的缓冲队列为空），如果发送数据协程队列不为空（这种情况下，此通道必为一个非缓冲通道），一个发送数据协程将从此队列中弹出，此协程欲发送的值将被接收数据协程Gr接收。此发送协程将恢复至运行状态。接收数据协程Gr继续运行，不会阻塞。对于这种情况，此数据接收操作为一个非阻塞操作。
    • 对于剩下的情况（即此通道的缓冲队列和发送数据协程队列均为空），此接收数据协程Gr将被推入接收数据协程队列，并进入阻塞状态。它以后可能会被另一个发送数据协程唤醒而恢复运行。对于这种情况，此数据接收操作为一个阻塞操作。通道操作情形B：当一个协程Gs尝试向一个非零且尚未关闭的通道发送数据的时候，此协程Gs将首先尝试获取此通道的锁，成功之后将执行下列步骤，直到其中一个步骤的条件得到满足。
    • 如果此通道的接收数据协程队列不为空（这种情况下，缓冲队列必为空），一个接收数据协程将从此队列中弹出，此协程将接收到发送协程Gs发送的值。此接收协程将恢复至运行状态。发送数据协程Gs继续运行，不会阻塞。对于这种情况，此数据发送操作为一个非阻塞操作。
    • 否则（接收数据协程队列为空），如果缓冲队列未满（这种情况下，发送数据协程队列必为空），发送协程欲Gs发送的值将被推入缓冲队列，发送数据协程Gs继续运行，不会阻塞。对于这种情况，此数据发送操作为一个非阻塞操作。
    • 对于剩下的情况（接收数据协程队列为空，并且缓冲队列已满），此发送协程Gs将被推入发送数据协程队列，并进入阻塞状态。它以后可能会被另一个接收数据协程唤醒而恢复运行。对于这种情况，此数据发送操作为一个阻塞操作。 上面已经提到过，一旦一个非零通道被关闭，继续向此通道发送数据将产生一个恐慌。注意，向关闭的通道发送数据属于一个非阻塞操作。 通道操作情形C：当一个协程成功获取到一个非零且尚未关闭的通道的锁并且准备关闭此通道时，下面两步将依次执行：
    • 如果此通道的接收数据协程队列不为空（这种情况下，缓冲队列必为空），此队列中的所有协程将被依个弹出，并且每个协程将接收到此通道的元素类型的一个零值，然后恢复至运行状态。
    • 如果此通道的发送数据协程队列不为空，此队列中的所有协程将被依个弹出，并且每个协程中都将产生一个恐慌（因为向已关闭的通道发送数据）。这就是我们在上面说并发地关闭一个通道和向此通道发送数据这种情形属于不良设计的原因。事实上，并发地关闭一个通道和向此通道发送数据将产生数据竞争。 注意：当一个缓冲队列不为空的通道被关闭之后，它的缓冲队列不会被清空，其中的数据仍然可以被后续的数据接收操作所接收到。详见下面的对情形D的解释。

    通道操作情形D：一个非零通道被关闭之后，此通道上的后续数据接收操作将永不会阻塞。此通道的缓冲队列中存储数据仍然可以被接收出来。伴随着这些接收出来的缓冲数据的第二个可选返回（类型不确定布尔）值仍然是true。一旦此缓冲队列变为空，后续的数据接收操作将永不阻塞并且总会返回此通道的元素类型的零值和值为false的第二个可选返回结果。上面已经提到了，一个接收操作的第二个可选返回（类型不确定布尔）结果表示一个接收到的值是否是在此通道被关闭之前发送的。如果此返回值为false，则第一个返回值必然是一个此通道的元素类型的零值。

    知道哪些通道操作是阻塞的和哪些是非阻塞的对正确理解后面将要介绍的select流程控制机制非常重要。

    如果一个协程被从一个通道的某个队列中（不论发送数据协程队列还是接收数据协程队列）弹出，并且此协程是在一个select控制流程中推入到此队列的，那么此协程将在下面将要讲解的中的第9步中恢复至运行状态，并且同时它会被从相应的select控制流程中的相关的若干通道的协程队列中移除掉。 根据上面的解释，我们可以得出如下的关于一个通道的内部的三个队列的各种事实：

    • 如果一个通道已经关闭了，则它的发送数据协程队列和接收数据协程队列肯定都为空，但是它的缓冲队列可能不为空。
    • 在任何时刻，如果缓冲队列不为空，则接收数据协程队列必为空。
    • 在任何时刻，如果缓冲队列未满，则发送数据协程队列必为空。
    • 如果一个通道是缓冲的，则在任何时刻，它的发送数据协程队列和接收数据协程队列之一必为空。
    • 如果一个通道是非缓冲的，则在任何时刻，一般说来，它的发送数据协程队列和接收数据协程队列之一必为空，但是有一个例外：一个协程可能在一个select流程控制中同时被推入到此通道的发送数据协程队列和接收数据协程队列中。

    一些通道的使用例子

    来看一些通道的使用例子来加深一下对上一节中的解释的理解。 一个简单的通过一个非缓冲通道实现的请求/响应的例子：

    1. package main
    3. import (
    4.     "fmt"
    5.     "time"
    6. )
    8. func main() {
    9.     c := make(chan int) // 一个非缓冲通道
    10.     go func(ch chan<- int, x int) {
    11.         time.Sleep(time.Second)
    12.         // <-ch    // 此操作编译不通过
    13.     }(c, 3)
    14.     done := make(chan struct{})
    15.     go func(ch <-chan int) {
    16.         n := <-ch      // 阻塞在此，直到有值发送到c
    17.         fmt.Println(n) // 9
    18.         // ch <- 123   // 此操作编译不通过
    19.         time.Sleep(time.Second)
    20.         done <- struct{}{}
    21.     }(c)
    22.     <-done // 阻塞在此，直到有值发送到done
    23.     fmt.Println("bye")
    24. }

    输出结果：

    1. 9
    2. bye

    下面的例子使用了一个缓冲通道。此例子程序并非是一个并发程序，它只是为了展示缓冲通道的使用。

    1. package main
    3. import "fmt"
    5. func main() {
    6.     c := make(chan int, 2) // 一个容量为2的缓冲通道
    7.     c <- 3
    8.     c <- 5
    9.     close(c)
    10.     fmt.Println(len(c), cap(c)) // 2 2
    11.     x, ok := <-c
    12.     fmt.Println(x, ok) // 3 true
    13.     fmt.Println(len(c), cap(c)) // 1 2
    14.     x, ok = <-c
    15.     fmt.Println(x, ok) // 5 true
    16.     fmt.Println(len(c), cap(c)) // 0 2
    17.     x, ok = <-c
    18.     fmt.Println(x, ok) // 0 false
    19.     x, ok = <-c
    20.     fmt.Println(x, ok) // 0 false
    21.     fmt.Println(len(c), cap(c)) // 0 2
    22.     close(c) // 此行将产生一个恐慌
    23.     c <- 7   // 如果上一行不存在，此行也将产生一个恐慌。
    24. }
    1. package main
    3. import (
    4.     "fmt"
    5.     "time"
    6. )
    8. func main() {
    9.     var ball = make(chan string)
    10.     kickBall := func(playerName string) {
    11.         for {
    12.             fmt.Print(<-ball, "传球", "\n")
    13.             time.Sleep(time.Second)
    14.             ball <- playerName
    15.         }
    16.     }
    17.     go kickBall("张三")
    18.     go kickBall("李四")
    19.     go kickBall("王二麻子")
    20.     go kickBall("刘大")
    21.     ball <- "裁判"   // 开球
    22.     var c chan bool // 一个零值nil通道
    23. }

    请阅读通道用例大全来查看更多通道的使用例子。

    通道的元素值的传递都是复制过程

    在一个值被从一个协程传递到另一个协程的过程中，此值将被复制至少一次。如果此传递值曾经在某个通道的缓冲队列中停留过，则它在此传递过程中将被复制两次。一次复制发生在从发送协程向缓冲队列推入此值的时候，另一个复制发生在接收协程从缓冲队列取出此值的时候。和赋值以及函数调用传参一样，当一个值被传递时，只有它的直接部分被复制。

    对于官方标准编译器，最大支持的通道的元素类型的尺寸为65535。但是，一般说来，为了在数据传递过程中避免过大的复制成本，我们不应该使用尺寸很大的通道元素类型。如果欲传送的值的尺寸较大，应该改用指针类型做为通道的元素类型。

    关于通道和协程的垃圾回收

    注意，一个通道被其发送数据协程队列和接收数据协程队列中的所有协程引用着。因此，如果一个通道的这两个队列只要有一个不为空，则此通道肯定不会被垃圾回收。另一方面，如果一个协程处于一个通道的某个协程队列之中，则此协程也肯定不会被垃圾回收，即使此通道仅被此协程所引用。事实上，一个协程只有在退出后才能被垃圾回收。

    数据接收和发送操作都属于简单语句。另外一个数据接收操作总是可以被用做一个单值表达式。简单语句和表达式可以被用在的某些部分。 在下面这个例子中，数据接收和发送操作被用在两个for循环的初始化和步尾语句。

    for-range应用于通道

    for-range循环控制流程也适用于通道。此循环将不断地尝试从一个通道接收数据，直到此通道关闭并且它的缓冲队列中为空为止。和应用于数组/切片/映射的for-range语法不同，应用于通道的for-range语法中最多只能出现一个循环变量，此循环变量用来存储接收到的值。

    1. for v = range aChannel {
    2.     // 使用v
    3. }

    等价于

    1. for {
    2.     v, ok = <-aChannel
    3.     if !ok {
    4.         break
    5.     }
    6.     // 使用v
    7. }

    当然，这里的通道aChannel一定不能为一个单向发送通道。如果它是一个nil零值，则此for-range循环将使当前协程永久阻塞。 上一节中的例子中的最后一个循环可以改写为下面这样：

    1.     for x := range c {
    2.         time.Sleep(time.Second)
    3.         fmt.Println(x)
    4.     }

    select-case分支流程控制代码块

    Go中有一个专门为通道设计的select-case分支流程控制语法。此语法和switch-case分支流程控制语法很相似。比如，select-case流程控制代码块中也可以有若干case分支和最多一个default分支。但是，这两种流程控制也有很多不同点。在一个select-case流程控制中，

    • select关键字和{之间不允许存在任何表达式和语句。
    • fallthrough语句不能被使用.
    • 每个case关键字后必须跟随一个通道接收数据操作或者一个通道发送数据操作。通道接收数据操作可以做为源值出现在一条简单赋值语句中。以后，一个case关键字后跟随的通道操作将被称为一个case操作。
    • 所有的非阻塞case操作中将有一个被随机选择执行（而不是按照从上到下的顺序），然后执行此操作对应的case分支代码块。
    • 在所有的case操作均为阻塞的情况下，如果default分支存在，则default分支代码块将得到执行；否则，当前协程将被推入所有阻塞操作中相关的通道的发送数据协程队列或者接收数据协程队列中，并进入阻塞状态。 按照上述规则，一个不含任何分支的select-case代码块select{}将使当前协程处于永久阻塞状态。 在下面这个例子中，default分支将铁定得到执行，因为另两个case分支后的操作均为阻塞的。
    1. package main
    3. import "fmt"
    5. func main() {
    6.     var c chan struct{} // nil
    7.     select {
    8.     case <-c:             // 阻塞操作
    9.     case c <- struct{}{}: // 阻塞操作
    10.     default:
    11.         fmt.Println("Go here.")
    12.     }
    13. }

    下面这个例子中实现了尝试发送（try-send）和尝试接收（try-receive）。它们都是用含有一个case分支和一个default分支的select-case代码块来实现的。

    下面这个程序有50%的几率会因为恐慌而崩溃。此程序中select-case代码块中的两个case操作均不阻塞，所以随机一个将被执行。如果第一个case操作（向已关闭的通道发送数据）被执行，则一个恐慌将产生。

    1. package main
    3. func main() {
    4.     c := make(chan struct{})
    5.     close(c)
    6.     select {
    7.     case c <- struct{}{}: // 若此分支被选中，则产生一个恐慌
    8.     case <-c:
    9.     }
    10. }

    select-case流程控制的实现机理

    select-case流程控制是Go中的一个重要和独特的特性。下面列出了官方标准运行时中select-case流程控制的实现步骤。

    • 将所有case操作中涉及到的通道表达式和发送值表达式按照从上到下，从左到右的顺序一一估值。在赋值语句中做为源值的数据接收操作对应的目标值在此时刻不需要被估值。
    • 将所有分支的随机排序。default分支总是排在最后。所有case操作中相关的通道可能会有重复的。
    • 为了防止在下一步中造成死锁，对所有case操作中相关的通道进行排序。排序依据并不重要，可以按照它们的地址顺序进行排序。排序结果中前N个通道不存在重复的情况。N为所有case操作中不重复的通道的数量。下面，通道锁顺序是针对此排序结果中的前N个通道来说的，通道锁逆序是指此顺序的逆序。
    • 按照上一步中的生成通道锁顺序获取所有相关的通道的锁。
    • 按照第2步中生成的分支顺序检查相应分支：
      • 如果这是一个case分支并且相应的通道操作是一个向关闭了的通道发送数据操作，则按照通道锁逆序解锁所有的通道并在当前协程中产生一个恐慌。跳到第12步。
      • 如果这是一个case分支并且相应的通道操作是非阻塞的，则按照通道锁逆序解锁所有的通道并执行相应的case分支代码块。（此相应的通道操作可能会唤醒另一个处于阻塞状态的协程。）跳到第12步。
      • 如果这是default分支，则按照通道锁逆序解锁所有的通道并执行此default分支代码块。跳到第12步。（到这里，default分支肯定是不存在的，并且所有的case操作均为阻塞的。）
    • 将当前协程（和对应case分支信息）推入到每个case操作中对应的通道的发送数据协程队列或接收数据协程队列中。当前协程可能会被多次推入到同一个通道的这两个队列中，因为多个case操作中对应的通道可能为同一个。
    • 使当前协程进入阻塞状态并则按照通道锁逆序解锁所有的通道。
    • …，当前协程处于阻塞状态，等待其它协程通过通道操作唤醒当前协程，…
    • 当前协程被另一个协程中的一个通道操作唤醒。此唤醒通道操作可能是一个通道关闭操作，也可能是一个数据发送/接收操作。如果它是一个数据发送/接收操作，则（当前正被解释的select-case流程中）肯定有一个相应case操作与之配合传递数据。在此配合过程中，当前协程将从相应case操作相关的通道的接收/发送数据协程队列中弹出。
    • 按照第3步中的生成的通道锁顺序获取所有相关的通道的锁。
    • 将当前协程从各个case操作中对应的通道的发送数据协程队列或接收数据协程队列中（可能以非弹出的方式）移除。
      • 如果当前协程时被一个通道关闭操作所唤醒，则跳到第5步。
      • 如果当前协程时被一个数据发送/接收操作所唤醒，则相应的case分支已经在第9步中知晓。按照通道锁逆序解锁所有的通道并执行此分支代码块。
    • 完毕。从此实现中，我们得知
    • 当一个协程被阻塞在一个select-case流程控制中并在以后被唤醒时，它可能会从多个通道的发送数据协程队列和接收数据协程队列中被移除。

    我们可以在一文中找到更多通道的使用例子。

    尽管通道可以帮助我们轻松地写出正确的并发代码，和其它并发同步技术一样，通道并不会阻止我们。

    通道并非在任何场合总是最佳的并发同步方案，请阅读其它并发同步技术和来了解Go中支持的更多的并发同步技术。

    Go语言101项目目前同时托管在Github和上。欢迎各位在这两个项目中通过提交bug和PR的方式来改进完善Go语言101中的各篇文章。