协程通信的利器：Go lang中的通道（channel）

2023-12-10 10:52:55

在Go语言中，通道（channel）是一种用于协程间通信的特殊类型。通道可以看作一个缓冲区，用于在协程之间安全地传递数据。本教程将详细介绍Go语言中通道的使用方法，帮助你掌握协程通信的基本原理。

通道基础

通道是一种类型化的数据结构，可以存储任意类型的数据。要创建一个通道，可以使用make函数。make函数的第一个参数是通道的类型，第二个参数是通道的缓冲区大小。缓冲区大小决定了通道可以同时容纳多少个数据。如果缓冲区大小为0，则通道为无缓冲通道。

// 创建一个无缓冲通道，用于传递int类型的数据
ch := make(chan int)

发送和接收数据

要向通道发送数据，可以使用<-运算符。<-运算符的作用是将数据发送到通道。如果通道已满，则发送操作会被阻塞，直到通道中有空间可以存放数据。

// 向通道发送数据
ch <- 10

要从通道接收数据，可以使用<运算符。<运算符的作用是从通道接收数据。如果通道为空，则接收操作会被阻塞，直到通道中有数据可以接收。

// 从通道接收数据
data := <-ch

通道同步

通道可以用于实现协程之间的同步。要实现协程之间的同步，可以使用select语句。select语句可以同时监听多个通道，当某个通道有数据可读或可写时，select语句就会选择该通道并执行相应的操作。

select {
case data := <-ch1:
    // 从通道ch1接收数据
case ch2 <- data:
    // 向通道ch2发送数据
default:
    // 如果ch1和ch2都为空，则执行default分支
}

通道关闭

通道可以通过close函数关闭。一旦通道关闭，就不能再向通道发送数据。关闭通道后，从通道接收数据的操作仍然可以继续，直到通道为空。

// 关闭通道
close(ch)

通道示例

以下是一个使用通道实现协程通信的示例：

package main

import (
    "fmt"
    "time"
)

func main() {
    // 创建一个无缓冲通道，用于传递int类型的数据
    ch := make(chan int)

    // 创建一个协程，向通道发送数据
    go func() {
        for i := 0; i < 10; i++ {
            ch <- i
            time.Sleep(100 * time.Millisecond)
        }
        close(ch) // 关闭通道
    }()

    // 创建一个协程，从通道接收数据
    go func() {
        for {
            data, ok := <-ch
            if !ok { // 如果通道已关闭，则退出循环
                break
            }
            fmt.Println(data)
        }
    }()

    // 等待协程结束
    time.Sleep(1 * time.Second)
}