面试题：Go中I/O复用与并发性能优化

1. select的使用场景优化

减少不必要的select分支：在select语句中，只保留必要的通道操作。每一个额外的分支都会增加运行时的开销，特别是在高并发环境下。例如，如果某些通道仅在特定条件下使用，应在条件满足时动态地构造select语句，而不是一直包含在select中。

if condition {
    select {
    case <-channel1:
        // 处理逻辑
    default:
        // 默认逻辑
    }
} else {
    select {
    case <-channel2:
        // 处理逻辑
    default:
        // 默认逻辑
    }
}

避免空的select：空的select语句（没有default分支且没有任何可操作的通道）会导致goroutine永久阻塞。确保select语句中至少有一个可操作的通道或default分支来处理非阻塞情况。

select {
case data := <-readChannel:
    // 处理读取的数据
default:
    // 当readChannel没有数据时的处理逻辑
}

优先处理紧急通道：如果有多个通道在select中，将处理紧急情况的通道放在前面。例如，用于关闭信号的通道应该优先处理，以确保在需要时能够快速停止goroutine。

select {
case <-shutdownChannel:
    // 执行关闭操作
case data := <-dataChannel:
    // 处理数据
}

2. goroutine的调度优化

合理限制goroutine数量：过多的goroutine会消耗大量系统资源，导致调度开销增大。可以使用sync.WaitGroup和channel来限制同时运行的goroutine数量。例如，创建一个带缓冲的channel作为信号量，控制并发数。

var semaphore = make(chan struct{}, 100) // 最多允许100个goroutine并发
var wg sync.WaitGroup
for _, conn := range connections {
    semaphore <- struct{}{}
    wg.Add(1)
    go func(c net.Conn) {
        defer func() {
            <-semaphore
            wg.Done()
        }()
        // 处理连接的逻辑
    }(conn)
}
wg.Wait()

优化goroutine的生命周期：尽量减少goroutine的创建和销毁频率。可以使用goroutine池来复用已有的goroutine，避免频繁创建和销毁带来的开销。例如，使用worker pool模式。

type Worker struct {
    taskChan chan func()
    stopChan chan struct{}
}

func NewWorker(taskChan chan func()) *Worker {
    return &Worker{
        taskChan: taskChan,
        stopChan: make(chan struct{}),
    }
}

func (w *Worker) Start() {
    go func() {
        for {
            select {
            case task := <-w.taskChan:
                task()
            case <-w.stopChan:
                return
            }
        }
    }()
}

func (w *Worker) Stop() {
    w.stopChan <- struct{}{}
}

避免goroutine饥饿：在调度任务时，确保所有的goroutine都有机会执行。避免某个goroutine长时间占用资源，导致其他goroutine得不到执行机会。例如，在处理长任务时，可以适当让出CPU时间片，使用runtime.Gosched()函数。

func longRunningTask() {
    for i := 0; i < 1000000; i++ {
        if i%1000 == 0 {
            runtime.Gosched()
        }
        // 具体任务逻辑
    }
}

3. 资源管理优化

连接池的使用：对于网络连接等资源，使用连接池来复用连接，减少连接创建和销毁的开销。例如，使用database/sql包中的连接池来管理数据库连接。

db, err := sql.Open("mysql", "user:password@tcp(127.0.0.1:3306)/database")
if err != nil {
    // 处理错误
}
defer db.Close()

// 设置最大空闲连接数和最大打开连接数
db.SetMaxIdleConns(10)
db.SetMaxOpenConns(100)

及时释放资源：在goroutine结束时，确保及时释放所有已获取的资源，如文件描述符、网络连接等。使用defer语句来保证资源的正确释放。

func handleConnection(conn net.Conn) {
    defer conn.Close()
    // 处理连接的逻辑
}

内存管理：在处理大量数据时，注意内存的分配和释放。避免内存泄漏，例如，及时清空不再使用的切片和映射。

var data []byte
// 处理数据
data = nil // 释放内存

星途面试题库

面试题：Go中I/O复用与并发性能优化

知识考点

面试题答案

1. select的使用场景优化

2. goroutine的调度优化

3. 资源管理优化