面试题：Go语言中Go race detector检测复杂并发问题

利用Go race detector排查并发问题的步骤：
- 启用race detector：在编译和运行Go程序时，添加-race标志。例如，编译命令为go build -race，运行命令为go run -race main.go。这样，Go运行时系统会检测程序中的数据竞争情况。
- 运行程序：正常运行程序，尽量覆盖所有可能涉及并发操作的路径和场景，使潜在的并发问题暴露出来。
- 分析race detector输出：race detector发现数据竞争时，会输出详细的信息，包括竞争发生的位置（文件名和行号）、涉及的变量以及竞争的操作（读或写）。根据这些信息，定位到具体的代码位置进行分析。
排查过程中重点关注的方面：
- channel的使用：
  - 未缓冲channel的收发同步：确保发送和接收操作在不同的goroutine中正确配对。如果发送操作在没有接收者的情况下执行，或者接收操作在没有发送者的情况下执行，可能导致死锁。例如：

package main

import (
    "fmt"
)

func main() {
    ch := make(chan int)
    ch <- 1 // 这里会阻塞，因为没有接收者
    fmt.Println(<-ch)
}

 - **缓冲channel的容量**：确保缓冲channel的容量设置合理，避免因为容量过小导致发送操作阻塞，或者容量过大导致数据在channel中积压未及时处理。
 - **关闭channel**：确保在合适的时机关闭channel，避免向已关闭的channel发送数据（会导致`panic`），或者从已关闭的channel接收数据后未正确处理（多次接收已关闭channel会返回零值）。例如：

package main

import (
    "fmt"
)

func main() {
    ch := make(chan int)
    close(ch)
    _, ok := <-ch
    if!ok {
        fmt.Println("channel is closed")
    }
}

共享资源的访问：
- 读写操作：确保对共享资源的读写操作是同步的，避免多个goroutine同时读写共享资源导致数据不一致。例如：

package main

import (
    "fmt"
    "sync"
)

var num int
var mu sync.Mutex

func increment(wg *sync.WaitGroup) {
    defer wg.Done()
    mu.Lock()
    num++
    mu.Unlock()
}

func main() {
    var wg sync.WaitGroup
    for i := 0; i < 10; i++ {
        wg.Add(1)
        go increment(&wg)
    }
    wg.Wait()
    fmt.Println("Final value:", num)
}

 - **初始化顺序**：注意共享资源的初始化顺序，尤其是在多个goroutine可能同时访问初始化后的资源时，确保初始化操作完成后再进行并发访问。

同步原语的使用：
- 互斥锁（Mutex）：合理使用互斥锁来保护共享资源，避免死锁（例如，多个goroutine相互等待对方释放锁）。
- 读写锁（RWMutex）：在读写操作频繁且读多写少的场景下，使用读写锁提高并发性能，同时要注意正确的读写锁操作顺序。
- WaitGroup：确保在使用WaitGroup时，Add、Done和Wait方法的调用顺序和计数正确，避免goroutine提前退出或等待永远不会完成的操作。

星途面试题库

面试题：Go语言中Go race detector检测复杂并发问题

知识考点

面试题答案