如何在 Go 中安全地通过通道传递切片并避免数据竞争-Golang-PHP中文网

如何在 Go 中安全地通过通道传递切片并避免数据竞争

本文详解如何修正 goroutine 间共享切片导致的数据竞争问题，通过消除全局变量共享、正确关闭通道及同步消费，确保多协程场景下数组合并结果确定且线程安全。

本文详解如何修正 goroutine 间共享切片导致的数据竞争问题，通过消除全局变量共享、正确关闭通道及同步消费，确保多协程场景下数组合并结果确定且线程安全。

在 Go 并发编程中，一个常见误区是让多个 goroutine 共享并修改同一个切片变量（如示例中的全局 x），这会引发严重的数据竞争（data race）——因为切片底层指向同一段底层数组，且 append 操作可能触发扩容并重新分配内存，导致不同 goroutine 的写入相互覆盖或丢失。Go 的 -race 检测器正是为此类问题而生。

? 根本问题分析

原代码存在两处关键竞态：

共享可变变量 x：所有 goroutine 共用同一个 x []string 变量，每次 x = cat_strings(...) 都会覆盖前一次赋值；更危险的是，若 cat_strings 返回的切片被并发写入 queue，而 x 又被后续 goroutine 复用，极易发生内存别名冲突。
异步消费与最终读取竞态：单独起 goroutine 消费 queue 并追加到 slice，而 main 函数在 wg.Wait() 后立即 fmt.Println(slice) —— 此时消费 goroutine 可能尚未完成，slice 处于未定义状态；同时 slice 本身也被多个 goroutine（消费者 + main）并发访问。

✅ 正确实践：无共享、有序消费、及时关闭

解决方案的核心原则是：每个 goroutine 独立生成数据，通过通道传递所有权，主 goroutine 单独、同步地收集结果。

使用Go语言搭建家庭相册系统-相关课件

下载

以下是修复后的完整代码：

package main

import (
    "fmt"
    "strconv"
    "sync"
)

func cat_strings(a int, b string) []string {
    y := make([]string, 0, 2) // 预分配容量，提升效率
    y = append(y, strconv.Itoa(a), b)
    return y
}

func main() {
    var result []string
    var wg sync.WaitGroup
    queue := make(chan []string, 10) // 缓冲通道，避免发送阻塞

    // 启动 10 个 goroutine，各自独立构造切片并发送
    wg.Add(10)
    for i := 0; i <h3>⚠️ 关键注意事项</h3>

绝不共享可变状态：x 变量已被彻底移除。每个 goroutine 调用 cat_strings 后获得全新切片，通过通道传递值语义（实际传递的是切片头信息，但因底层数组由各 goroutine 独立分配，故无共享风险）。
通道关闭时机至关重要：必须由 wg.Wait() 保证所有发送完成后再 close(queue)。若在 wg.Add 前关闭，或由某个 sender 提前关闭，会导致 range 漏掉数据或 panic。
消费必须同步在主 goroutine：避免另起 goroutine 异步消费 slice，否则需额外同步机制（如 mutex 或再次 wait）。直接 for range 是最简洁、最安全的方式。
缓冲通道大小合理：make(chan []string, 10) 匹配 goroutine 数量，防止发送方因接收方未启动而阻塞；若不确定数量，可用无缓冲通道 + 接收逻辑前置，但需注意死锁风险。