Golang channel代码示例：无缓冲、带缓冲、多路发送和接收

本是古典何须时尚 2024-02-19 10:29 59阅读 0赞

当然，我可以为您提供一些根据Go语言中channel的特点编写的详细代码示例。以下是不同类型的channel操作示例：

1.  **无缓冲channel**：

package main
    
    import "fmt"
    
    func main() {
        
        ch := make(chan int) // 创建一个无缓冲的channel
    
        // 启动一个goroutine将数据发送到channel
        go func() {
        
            ch <- 10 // 发送数据到channel
        }()
    
        // 从channel中读取数据
        if num, ok := <-ch; ok {
        
            fmt.Println("读取到数据:", num)
        } else {
        
            fmt.Println("Channel已关闭")
        }
    }

这个示例展示了如何使用无缓冲channel进行基本的发送和接收操作。由于channel没有缓冲区，发送操作将阻塞直到接收操作准备好。在示例中，我们只发送了一个值到channel，所以接收操作会立即执行。

1.  **缓冲channel**：

package main
    
    import "fmt"
    
    func main() {
        
        ch := make(chan int, 2) // 创建一个具有2个缓冲空间的channel
    
        // 启动一个goroutine将数据发送到channel
        go func() {
        
            for i := 1; i <= 5; i++ {
        
                ch <- i // 发送数据到channel
            }
            close(ch) // 关闭channel
        }()
    
        // 从channel中读取数据
        for {
        
            if num, ok := <-ch; ok {
        
                fmt.Println("读取到数据:", num)
            } else {
        
                break // channel已经关闭，退出循环
            }
        }
    }

这个示例展示了如何使用缓冲channel。在创建channel时，我们指定了2个缓冲空间。这意味着在接收操作准备好之前，我们可以发送两个值到channel，然后发送操作将阻塞。在这个示例中，我们在发送5个值之后关闭了channel，并继续从channel中读取数据直到读取到空数据。

1.  **多路发送和接收**：

package main
    
    import "fmt"
    
    func main() {
        
        ch := make(chan int) // 创建一个无缓冲的channel
        done := make(chan bool) // 创建一个用于通知的channel
    
        // 启动一个goroutine将数据发送到channel和一个goroutine从channel接收数据
        go func() {
        
            for i := 1; i <= 5; i++ {
        
                ch <- i // 发送数据到channel
            }
            close(ch) // 关闭channel
            done <- true // 通知完成
        }()
        go func() {
        
            for num := range ch {
         // 从channel接收数据并处理它们
                fmt.Println("接收到的数据:", num)
            }
        }()
    
        // 等待完成通知并退出程序
        <-done // 等待完成通知并退出程序中的第一个goroutine（发送数据）完成执行。它不会阻塞第二个goroutine（接收数据）的执行。第二个goroutine会继续执行直到通道关闭并完成。因此，程序会等待第一个goroutine完成并打印出所有接收到的数据。然后程序退出。