面试题：Go Select语句与并发安全及性能优化

高并发场景下Select语句的并发安全问题

资源竞争：当多个goroutine同时通过select操作同一个通道时，可能会出现资源竞争问题。例如，多个goroutine同时向一个已满的通道发送数据，或者从一个已空的通道接收数据，这可能导致程序出现未定义行为。
死锁：如果select语句中的所有通道操作都阻塞（例如所有发送操作的通道已满，所有接收操作的通道已空），并且没有default分支，就会发生死锁。

性能优化方法及代码示例

避免不必要的通道操作：尽量减少在select语句中不必要的通道操作。例如，如果一个通道只在特定条件下使用，可以在select外部进行条件判断。

package main

import (
    "fmt"
    "time"
)

func main() {
    ch1 := make(chan int)
    ch2 := make(chan int)
    var condition bool = true

    go func() {
        time.Sleep(2 * time.Second)
        ch1 <- 1
    }()

    if condition {
        select {
        case data := <-ch1:
            fmt.Println("Received from ch1:", data)
        case <-time.After(3 * time.Second):
            fmt.Println("Timeout")
        }
    } else {
        select {
        case data := <-ch2:
            fmt.Println("Received from ch2:", data)
        case <-time.After(3 * time.Second):
            fmt.Println("Timeout")
        }
    }
}

合理设置default分支：在select语句中添加default分支可以避免阻塞，提高程序的响应性。但要注意，default分支会在所有通道操作都不可用时立即执行，可能会导致忙等待，消耗CPU资源，所以要谨慎使用。

package main

import (
    "fmt"
)

func main() {
    ch := make(chan int)

    select {
    case data := <-ch:
        fmt.Println("Received:", data)
    default:
        fmt.Println("No data available immediately")
    }
}

使用带缓冲的通道：在大量通道操作时，使用带缓冲的通道可以减少阻塞的可能性，提高性能。例如，在生产者 - 消费者模型中，生产者向带缓冲的通道发送数据，消费者从通道接收数据。

package main

import (
    "fmt"
)

func producer(ch chan<- int) {
    for i := 0; i < 10; i++ {
        ch <- i
    }
    close(ch)
}

func consumer(ch <-chan int) {
    for data := range ch {
        fmt.Println("Consumed:", data)
    }
}

func main() {
    ch := make(chan int, 5) // 带缓冲的通道
    go producer(ch)
    consumer(ch)
}

多路复用通道：当有多个通道需要监听，且某些通道的数据处理逻辑相似时，可以将这些通道进行多路复用，减少select语句的复杂度。

package main

import (
    "fmt"
    "time"
)

func main() {
    ch1 := make(chan int)
    ch2 := make(chan int)

    go func() {
        time.Sleep(1 * time.Second)
        ch1 <- 1
    }()

    go func() {
        time.Sleep(2 * time.Second)
        ch2 <- 2
    }()

    combinedCh := make(chan int)
    go func() {
        for {
            select {
            case data := <-ch1:
                combinedCh <- data
            case data := <-ch2:
                combinedCh <- data
            }
        }
    }()

    for i := 0; i < 2; i++ {
        select {
        case data := <-combinedCh:
            fmt.Println("Received from combinedCh:", data)
        }
    }
}

星途面试题库

面试题：Go Select语句与并发安全及性能优化

知识考点

面试题答案

高并发场景下Select语句的并发安全问题

性能优化方法及代码示例