当前位置：首页 > 文章列表 > Golang > Go教程 > Golang 函数：通道并发通信中的缓冲与非缓冲问题

Golang 函数：通道并发通信中的缓冲与非缓冲问题

2024-10-26 17:29:44 0浏览收藏

在IT行业这个发展更新速度很快的行业，只有不停止的学习，才不会被行业所淘汰。如果你是Golang学习者，那么本文《Golang 函数：通道并发通信中的缓冲与非缓冲问题》就很适合你！本篇内容主要包括##content_title##，希望对大家的知识积累有所帮助，助力实战开发！

在 Go 中，通道分为缓冲和非缓冲两种。缓冲通道允许协程间存储数据，发送和接收不会阻塞，但消耗更多内存。非缓冲通道一次只能存储一个值，发送和接收会立即阻塞，同步效果更好。选择通道类型时，需考虑吞吐量、同步和资源消耗等因素。

Go 语言中的通道缓冲与非缓冲：并行通信剖析

在 Go 语言中，通道是一个用来在协程之间安全传输数据的队列。它们分为缓冲和非缓冲两种类型，每种类型都有其独特的特性和用例。

缓冲通道

缓冲通道允许在发送者和接收者之间存储一定数量的数据，从而避免协程因缓冲区已满或为空而阻塞。当向缓冲通道发送数据时，如果缓冲区已满，发送者将被阻塞，直到有空间可用为止。同样，当从缓冲通道接收数据时，如果缓冲区为空，接收者将被阻塞，直到有数据可用为止。

代码示例：缓冲通道

package main

import (
    "fmt"
    "sync"
)

func main() {
    // 创建一个容量为 5 的缓冲通道
    c := make(chan int, 5)

    var wg sync.WaitGroup

    // 向通道发送 10 个值
    for i := 0; i < 10; i++ {
        wg.Add(1)
        go func(i int) {
            c <- i
            defer wg.Done()
        }(i)
    }

    // 从通道接收 10 个值
    for i := 0; i < 10; i++ {
        fmt.Println(<-c)
    }

    wg.Wait()
}

在上面的示例中，尽管发送和接收协程同时运行，但由于缓冲通道的缓冲能力，它们不会阻塞。

非缓冲通道

非缓冲通道在任何时候都最多只存储一个值。向非缓冲通道发送数据时，如果接收者没有准备好，发送者将被立即阻塞。同样，当从非缓冲通道接收数据时，如果发送者没有准备好，接收者将被立即阻塞。

代码示例：非缓冲通道

package main

import (
    "fmt"
    "sync"
)

func main() {
    // 创建一个非缓冲通道
    c := make(chan int)

    var wg sync.WaitGroup

    // 向通道发送 10 个值
    for i := 0; i < 10; i++ {
        wg.Add(1)
        go func(i int) {
            c <- i
            defer wg.Done()
        }(i)
    }

    // 从通道接收 10 个值，并强制顺序打印
    for i := 0; i < 10; i++ {
        <-c
        fmt.Println(i)
    }

    wg.Wait()
}

在上面的示例中，发送和接收协程都是交替进行的，因为非缓冲通道的非阻塞特性。

选择缓冲和非缓冲通道

在选择缓冲和非缓冲通道时，需要考虑以下因素：