Go 并发编程：使用 Channel 实现 Goroutine 间通信

DDD

发布时间：2025-08-16 19:42:02

1006人浏览过

来源于php中文网

原创

go 并发编程：使用 channel 实现 goroutine 间通信

本文深入探讨了 Go 语言中 Goroutine 间通过 Channel 进行通信的机制。通过实例代码，展示了如何使用 Channel 实现数据在 Goroutine 之间的传递，以及如何优雅地处理 Goroutine 的生命周期，避免资源泄漏和死锁等问题。本文旨在帮助读者理解 Go 并发编程的核心概念，并掌握 Channel 的使用技巧。

Channel 的基本使用

在 Go 语言中，Channel 是一种类型化的管道，可以用于在 Goroutine 之间传递数据。Channel 必须先创建才能使用，可以使用 make 函数创建 Channel。

ch := make(chan int) // 创建一个可以传递 int 类型数据的 Channel

创建 Channel 后，可以使用

ch <- 10 // 向 Channel 发送数据 10
value := <-ch // 从 Channel 接收数据，并将结果赋值给 value

默认情况下，Channel 的发送和接收操作是阻塞的。也就是说，如果 Channel 中没有数据，接收操作将会阻塞，直到有数据可接收；如果 Channel 已满，发送操作将会阻塞，直到 Channel 中有空间可以发送数据。

使用 Channel 实现 Goroutine 间通信

以下示例展示了如何使用 Channel 实现两个 Goroutine 之间的通信：

package main

import "fmt"

func Send(ch chan<- int) {
    for i := 0; i < 10; i++ {
        fmt.Println(i, " sending")
        ch <- i
    }
    close(ch) // 发送完毕后关闭 Channel
}

func Receive(ch <-chan int) {
    for value := range ch { // 使用 range 循环接收 Channel 中的数据，直到 Channel 关闭
        fmt.Println(value, " received")
    }
}

func main() {
    ch := make(chan int)
    go Receive(ch)
    Send(ch)
}

在这个例子中，Send 函数向 Channel 发送 0 到 9 这 10 个整数，然后关闭 Channel。Receive 函数从 Channel 接收数据，并打印接收到的值。main 函数创建 Channel，并启动 Receive Goroutine，然后调用 Send 函数。

注意事项：

在 Send 函数中，使用 close(ch) 关闭 Channel。关闭 Channel 是一个重要的操作，它可以通知 Receive Goroutine 数据发送完毕。如果没有关闭 Channel，Receive Goroutine 将会一直阻塞，等待新的数据，从而导致死锁。
在 Receive 函数中，使用 for value := range ch 循环接收 Channel 中的数据。range 循环会一直从 Channel 接收数据，直到 Channel 关闭。当 Channel 关闭时，range 循环会自动退出。

使用带缓冲的 Channel

除了无缓冲的 Channel，Go 还支持带缓冲的 Channel。带缓冲的 Channel 在创建时可以指定缓冲区的大小。

BizPower CRM客户管理系统

通过使用BizPower CRM解决方案，您的员工、生产过程及信息能够与客户保持着平稳、无间断的联络，并且能够通过以客户为焦点、创新的产品和服务；以客户为中心，更高层次的生产过程；持久有益的客户关系这三个方面创造有价值客户的领导关系。选择Bizpower CRM的原因1、灵活的数据权限和功能权限BizPower CRM 系统通过引入了灵活的数据权限和功能权限，模仿现实中协同工作的实际情况。实现企

下载

ch := make(chan int, 10) // 创建一个缓冲区大小为 10 的 Channel

带缓冲的 Channel 的发送操作只有在缓冲区满时才会阻塞，接收操作只有在缓冲区为空时才会阻塞。

双向通信示例

以下示例展示了如何使用两个 Channel 实现两个 Goroutine 之间的双向通信：

package main

import "fmt"

func Commander(commands chan int, responses chan int) {
    for i := 0; i < 10; i++ {
        fmt.Println(i, " command")
        commands <- i
        fmt.Println(<-responses, " response")
    }
    close(commands) // 发送完毕后关闭 commands Channel
}

func Responder(commands chan int, responses chan int) {
    for {
        x, open := <-commands
        if !open {
            return // commands Channel 关闭，退出循环
        }
        responses <- x + 2
    }
}

func main() {
    commands := make(chan int)
    responses := make(chan int)
    go Commander(commands, responses)
    Responder(commands, responses)
}

在这个例子中，Commander Goroutine 向 commands Channel 发送命令，并从 responses Channel 接收响应。Responder Goroutine 从 commands Channel 接收命令，并将命令加 2 后发送到 responses Channel。

注意事项：