Go语言教程：通道（Channel）2

通道的基本概念#

1. 创建通道：使用make函数创建一个通道。通道的类型由其传递的数据类型决定。

   1
   ch := make(chan int)
   

2. 发送数据：使用<-操作符将数据发送到通道。

   1
   ch <- 42
   

3. 接收数据：使用<-操作符从通道接收数据。

   1
   value := <-ch
   

4. 关闭通道：使用close函数关闭通道。关闭后的通道不能再发送数据，但可以继续接收数据，直到通道为空。

   1
   close(ch)
   

示例代码解析#

下面是一个完整的示例代码，展示了如何使用通道在两个goroutine之间传递数据。

1
package main
2

3
import "fmt"
4

5
func main() {
6
    ch1 := make(chan int, 2) // 创建一个缓冲区大小为2的通道
7

8
    // 发送方
9
    go func() {
10
        for i := 0; i < 10; i++ {
11
            fmt.Printf("Sender: sending element %v...\\n", i)
12
            ch1 <- i // 将数据发送到通道
13
        }
14
        fmt.Println("Sender: close the channel...")
15
        close(ch1) // 发送完数据后关闭通道
16
    }()
17

18
    // 接收方
19
    for {
20
        elem, ok := <-ch1 // 从通道接收数据
21
        if !ok { // 检查通道是否关闭
22
            fmt.Println("Receiver: closed channel")
23
            break
24
        }
25
        fmt.Printf("Receiver: received an element: %v\\n", elem)
26
    }
27

28
    fmt.Println("End.")
29
}

代码详解#

1. 创建通道：

   1
   ch1 := make(chan int, 2)
   

   这里我们创建了一个缓冲区大小为2的通道ch1。缓冲区允许通道在没有接收方的情况下存储最多2个元素。

2. 发送方goroutine：

   1
   go func() {
   2
       for i := 0; i < 10; i++ {
   3
           fmt.Printf("Sender: sending element %v...\\n", i)
   4
           ch1 <- i
   5
       }
   6
       fmt.Println("Sender: close the channel...")
   7
       close(ch1)
   8
   }()
   

   这个goroutine负责向通道发送数据。它在循环中发送10个整数到通道ch1，然后关闭通道。

3. 接收方：

   1
   for {
   2
       elem, ok := <-ch1
   3
       if !ok {
   4
           fmt.Println("Receiver: closed channel")
   5
           break
   6
       }
   7
       fmt.Printf("Receiver: received an element: %v\\n", elem)
   8
   }
   

   主goroutine在一个无限循环中从通道接收数据。elem, ok := <-ch1语句从通道接收数据，并检查通道是否关闭。如果通道关闭，ok将为false，循环终止。

4. 结束程序：

   1
   fmt.Println("End.")
   

   当接收方检测到通道关闭后，程序输出”End.”并结束。