面试题：Go语言有缓冲与无缓冲通道在高并发场景下的性能优化策略

优化思路

有缓冲通道与无缓冲通道的选择：
- 无缓冲通道：无缓冲通道是同步的，发送操作和接收操作会阻塞直到对方准备好。在生产者 - 消费者场景中，这意味着生产者每次发送数据后，必须等待消费者接收，反之亦然。这种严格的同步机制在高并发下可能导致频繁的阻塞，影响性能，所以在这种场景下不太适合使用无缓冲通道。
- 有缓冲通道：有缓冲通道允许在没有接收者的情况下发送一定数量的数据。在高并发的生产者 - 消费者场景中，生产者可以将数据快速发送到通道中，而不必等待消费者立即接收，这可以减少生产者的阻塞时间，提高整体性能。因此，在这种场景下，选择有缓冲通道更为合适。
通道容量的设置：
- 通道容量需要根据实际情况进行权衡。如果容量设置过小，生产者可能仍然会频繁阻塞等待通道有空间；如果容量设置过大，可能会占用过多内存，并且可能导致数据在通道中积压，不能及时被处理。
- 对于100个并发的生产者和50个并发的消费者的场景，可以考虑将通道容量设置为一个适中的值，比如50到100之间。例如设置为100，这样生产者可以在一定程度上并行地将数据发送到通道中，而消费者也有足够的数据进行处理，不会让通道过度积压。

代码示例

package main

import (
    "fmt"
    "sync"
)

func producer(id int, ch chan int, wg *sync.WaitGroup) {
    defer wg.Done()
    for i := 0; i < 10; i++ {
        data := id*10 + i
        ch <- data
        fmt.Printf("Producer %d sent: %d\n", id, data)
    }
}

func consumer(id int, ch chan int, wg *sync.WaitGroup) {
    defer wg.Done()
    for data := range ch {
        fmt.Printf("Consumer %d received: %d\n", id, data)
    }
}

func main() {
    var wg sync.WaitGroup
    ch := make(chan int, 100)

    // 启动100个生产者
    for i := 0; i < 100; i++ {
        wg.Add(1)
        go producer(i, ch, &wg)
    }

    // 启动50个消费者
    for i := 0; i < 50; i++ {
        wg.Add(1)
        go consumer(i, ch, &wg)
    }

    go func() {
        wg.Wait()
        close(ch)
    }()

    select {}
}

代码说明

通道创建：ch := make(chan int, 100) 创建了一个容量为100的有缓冲通道，用于生产者和消费者之间的数据传递。
生产者函数：producer 函数模拟生产者，将数据发送到通道中。每个生产者发送10个数据。
消费者函数：consumer 函数使用 for... range 从通道中接收数据，直到通道关闭。
主函数：在 main 函数中，启动100个生产者和50个消费者，并使用 sync.WaitGroup 等待所有生产者完成工作后关闭通道，这样可以避免性能瓶颈，即防止生产者因为通道已满而长时间阻塞，同时也能让消费者及时处理数据，不会因为通道无数据而阻塞太久。

星途面试题库

面试题：Go语言有缓冲与无缓冲通道在高并发场景下的性能优化策略

知识考点

面试题答案

优化思路

代码示例

代码说明