如何让多个 Go 协程尽可能同时启动-Golang-PHP中文网

如何让多个 Go 协程尽可能同时启动

本文介绍一种使用无缓冲通道（channel）配合 close() 实现多 goroutine “准同步”启动的可靠方法，解决传统 sync.WaitGroup 无法控制启动时机的问题。

本文介绍一种使用无缓冲通道（channel）配合 `close()` 实现多 goroutine “准同步”启动的可靠方法，解决传统 `sync.waitgroup` 无法控制启动时机的问题。

在 Go 中，go 关键字启动协程是异步且非阻塞的，协程实际开始执行的时间取决于调度器、系统负载和 GOMAXPROCS 设置，并不等于“声明启动”的时刻。因此，仅靠 sync.WaitGroup 只能等待协程完成，无法协调它们的起始时间。

要实现多个 goroutine 尽可能同时开始执行，核心思路是：让所有 goroutine 在真正工作前先统一阻塞等待一个信号，待主协程确认全部 goroutine 已就绪后，再一次性释放该信号。Go 中最轻量、最符合语义的方式是使用一个关闭即广播的空结构体通道（chan struct{}）。

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

下载

✅ 正确实现方式

package main

import (
    "flag"
    "fmt"
    "sync"
    "time"
)

func main() {
    var wg sync.WaitGroup
    routines := flag.Int("runs", 100, "number of goroutines to run")
    flag.Parse()

    // 创建一个无缓冲 channel，用于同步启动信号
    start := make(chan struct{})

    wg.Add(*routines)
    for i := 0; i <blockquote><p>? <strong>关键原理</strong>：对已关闭的 chan struct{} 执行 立即返回（不阻塞），且该行为是并发安全的。因此 close(start) 相当于向所有等待者发出“现在开始”的原子广播。</p></blockquote><h3>⚠️ 注意事项与限制</h3>

“同时”是近似的：受 Go 调度器、OS 线程切换、CPU 核心数等影响，严格意义上的纳秒级同步无法保证。但该方案在绝大多数场景下可达到微秒级精度，远优于裸 go 启动。
避免变量捕获陷阱：示例中 i 是循环变量，直接在闭包中使用会导致所有 goroutine 读取到相同的最终值（如 i == *routines）。实际使用时应传参（如 go func(id int)）或在循环内定义局部变量。
不要重复关闭 channel：close(start) 只能调用一次，多次调用 panic；也不应在未关闭时从多个 goroutine 写入（本例无需写入）。
GOMAXPROCS 影响并行度：若 goroutine 数量远超 runtime.GOMAXPROCS() 或物理 CPU 核心数，它们仍需共享线程，此时“同时运行”退化为“同时就绪、交替执行”。