面试题：Go语言闭包在高并发回调函数中的优化应用

可能出现的问题

内存泄漏：闭包捕获的外部变量如果没有及时释放，会导致内存一直被占用。例如，当闭包持有对大对象的引用，而这个闭包在长时间内都不会被垃圾回收（GC），因为闭包本身可能还在被使用，从而导致内存泄漏。
数据竞争：在高并发场景下，如果多个闭包同时访问和修改捕获的外部变量，会引发数据竞争问题。这可能导致程序出现不可预测的行为，例如结果错误、程序崩溃等。

优化方案

减少闭包捕获的变量范围：只捕获闭包真正需要的变量，避免不必要的变量捕获，从而减少内存占用。
使用并发控制机制：通过sync包中的工具来保护共享变量，避免数据竞争。例如使用sync.Mutex来互斥访问共享变量，或者使用sync.RWMutex在多读少写的场景下提高并发性能。

代码示例

使用sync.Mutex

package main

import (
    "fmt"
    "sync"
)

var (
    counter int
    mu      sync.Mutex
)

func main() {
    var wg sync.WaitGroup
    for i := 0; i < 10; i++ {
        wg.Add(1)
        go func() {
            defer wg.Done()
            mu.Lock()
            counter++
            mu.Unlock()
        }()
    }
    wg.Wait()
    fmt.Println("Final counter:", counter)
}

使用sync.RWMutex（适用于多读少写场景）

package main

import (
    "fmt"
    "sync"
)

var (
    data  int
    rwmu  sync.RWMutex
)

func readData() {
    rwmu.RLock()
    defer rwmu.RUnlock()
    fmt.Println("Read data:", data)
}

func writeData() {
    rwmu.Lock()
    data++
    rwmu.Unlock()
}

func main() {
    var wg sync.WaitGroup
    for i := 0; i < 5; i++ {
        wg.Add(1)
        go func() {
            defer wg.Done()
            writeData()
        }()
    }
    for i := 0; i < 10; i++ {
        wg.Add(1)
        go func() {
            defer wg.Done()
            readData()
        }()
    }
    wg.Wait()
}

减少闭包捕获变量范围示例

package main

import (
    "fmt"
)

func main() {
    largeData := make([]byte, 1024*1024) // 模拟大对象
    // 只捕获需要的变量
    num := 10
    var wg sync.WaitGroup
    for i := 0; i < num; i++ {
        localI := i // 避免闭包捕获循环变量i
        wg.Add(1)
        go func() {
            defer wg.Done()
            fmt.Println("Processing task:", localI)
        }()
    }
    wg.Wait()
    // largeData作用域结束，及时释放内存
}

星途面试题库

面试题：Go语言闭包在高并发回调函数中的优化应用

知识考点

面试题答案

可能出现的问题

优化方案

代码示例