- 正确答案：Go并发的核心是goroutine和channel，配合select、sync包（如Mutex、WaitGroup、Once等）以及context实现安全、高效、可控制的并发编程。典型手撕题如“用goroutine和channel实现生产者-消费者模型”或“限制并发数的批量HTTP请求”需体现协程调度意识、资源竞争规避、生命周期管理与错误传播能力。 - 解答思路：面试中手撕Go并发，不能只写go func(){}就结束——需体现工程级思考： 1）明确并发目标（如提高吞吐？解耦逻辑？响应实时性？）； 2）识别共享状态（是否需要互斥？用channel传递还是sync保护？）； 3）处理goroutine泄漏（如何优雅退出？是否使用done channel或context？）； 4）错误处理与传播（panic recover？error channel？）； 5）背压与限流（buffered channel大小？worker pool模式？）。以“固定N个worker并发处理任务队列”为例，应构造带缓冲channel的任务队列 + N个常驻goroutine + WaitGroup等待完成 + context控制超时/取消。 - 深度知识讲解： ▶ goroutine底层机制： Go运行时维护M:N调度器（M个OS线程映射N个goroutine），每个goroutine初始栈仅2KB（可动态扩缩至最大1GB），由g0（系统栈）、m（machine）、p（processor）三元组协同调度。goroutine阻塞在系统调用（如文件IO、网络read）时，会自动被M脱离并唤醒空闲M继续执行其他G，这是Go高并发的基础。注意：goroutine不是OS线程，创建开销极小（纳秒级），但滥用仍会导致内存和调度压力（如百万级goroutine未合理阻塞/退出）。 ▶ channel原理： channel是引用类型，底层为hchan结构体，含lock互斥锁、recvq/sendq等待队列（链表）、buf环形缓冲区（若为buffered）、sendx/recvx索引。unbuffered channel的send/recv必须配对阻塞（同步语义），而buffered channel允许一定异步容量。channel操作本质是原子状态机：goroutine在send时若无接收者且buf满，则入sendq挂起；recv同理。close(channel)会置closed标志，后续send panic，recv可读完剩余再读到零值。注意：nil channel在select中永远不可读/写（用于动态禁用分支）。 ▶ sync.WaitGroup原理：内部基于atomic计数器+信号量（sema）实现。Add(delta)原子增减计数；Done()等价Add(-1)；Wait()自旋+阻塞于sema——当计数非零时调用runtime_Semacquire，进入GPM调度等待。关键点：Add必须在Wait前调用（或确保可见性），否则可能Wait直接返回；计数不能为负（panic）；不适用于goroutine生命周期嵌套管理（应优先用context+done channel）。 ▶ context.Context作用与实现：是goroutine间传递截止时间、取消信号、请求范围值的树状结构。Deadline/Cancel/Value方法均通过interface{}向上递归查找。cancelCtx包含mu互斥锁、done channel（只关闭一次）、children map、parent Context。调用cancel()时，先关闭自身done，再遍历children递归cancel。注意：context.WithCancel(parent)返回的cancel函数必须显式调用，且只能调用一次；http.Request.Context()默认携带request timeout，应始终传递至下游IO操作（如database/sql、http.Client.Do）。 ▶ 并发安全陷阱： - 不要直接在goroutine中访问闭包变量（i++循环变量易错）→ 改用传参（go func(val int){...}(i)）； - map并发读写panic → 用sync.Map（适用于读多写少）或RWMutex保护普通map； - time.After在for循环中导致大量timer泄露 → 改用time.NewTimer().Reset()复用； - select{}永远阻塞，select{default:}非阻塞尝试，但可能忙等 → 合理结合time.After或context.WithTimeout。 - 代码示例（手撕高频题：带并发限制的批量HTTP请求）： func fetchUrls(urls []string, maxConcurrency int) map[string]string { results := make(map[string]string) mu := sync.RWMutex{} var wg sync.WaitGroup sem := make(chan struct{}, maxConcurrency) // 信号量控制并发数 for _, url := range urls { wg.Add(1) go func(u string) { defer wg.Done() sem <- struct{}{} // 获取令牌 defer func() { <-sem }() // 归还令牌 resp, err := http.Get(u) if err != nil { mu.Lock() results[u] = "ERROR: " + err.Error() mu.Unlock() return } defer resp.Body.Close() body, _ := io.ReadAll(resp.Body) mu.Lock() results[u] = string(body) mu.Unlock() }(url) } wg.Wait() return results } ✦ 更优解（用channel替代mutex，符合Go信条）： func fetchUrlsCh(urls []string, maxConcurrency int) map[string]string { type result struct { url, body string; err error } jobs := make(chan string, len(urls)) results := make(chan result, len(urls)) for _, u := range urls { jobs <- u } close(jobs) // 启动worker池 for i := 0; i < maxConcurrency; i++ { go func() { for url := range jobs { resp, err := http.Get(url) if err != nil { results <- result{url: url, err: err} continue } body, _ := io.ReadAll(resp.Body) resp.Body.Close() results <- result{url: url, body: string(body)} } }() } // 收集结果 out := make(map[string]string) for i := 0; i < len(urls); i++ { r := <-results if r.err != nil { out[r.url] = "ERROR: " + r.err.Error() } else { out[r.url] = r.body } } return out } ✦ 最佳实践增强版（加入context超时、错误聚合、重试）： func fetchWithCtx(ctx context.Context, urls []string, maxConcurrency int) (map[string]string, error) { results := make(map[string]string) var mu sync.Mutex var firstErr error var wg sync.WaitGroup sem := make(chan struct{}, maxConcurrency) for _, url := range urls { wg.Add(1) go func(u string) { defer wg.Done() select { case sem <- struct{}{}: case <-ctx.Done(): mu.Lock() if firstErr == nil { firstErr = ctx.Err() } mu.Unlock() return } defer func() { <-sem }() req, _ := http.NewRequestWithContext(ctx, "GET", u, nil) resp, err := http.DefaultClient.Do(req) if err != nil { mu.Lock() if firstErr == nil { firstErr = err } mu.Unlock() return } defer resp.Body.Close() body, _ := io.ReadAll(resp.Body) mu.Lock() results[u] = string(body) mu.Unlock() }(url) } wg.Wait() return results, firstErr } 上述代码覆盖了：goroutine启动、并发控制（semaphore channel）、context传播、错误聚合、资源清理（defer Close）、线程安全（mutex保护共享map）。面试时若能主动指出“此处map写入可改用sync.Map避免锁”或“body读取应设MaxBytesReader防OOM”，则体现深度工程素养。

Momenta一面

全站热榜

创作者周榜