Golang中多发送者向单一通道写入的实现问题

这当然是可行的！你遇到的modify2和modify3没执行的问题，大概率是代码里的并发逻辑没处理对——比如没把这些函数放到独立的goroutine里，或者主goroutine提前退出/阻塞了，导致后续函数根本没机会运行。咱们来拆解问题，再给出正确的实现方式。

先分析你可能踩的坑 #

你提到的第二个示例里，估计是直接在主goroutine里调用了这些修改函数，比如类似这样的写法：

func main() {
    ch := make(chan int)
    modify1(ch) // 这里没加go关键字，主goroutine会卡在这
    modify2(ch) // 永远不会执行到这里
    modify3(ch)
}

因为你用的是无缓冲channel，modify1(ch)执行到发送数据的步骤时，会一直阻塞，直到有接收端接收数据。而主goroutine被卡在modify1这里，自然就轮不到modify2和modify3运行了。

正确实现方案：并发goroutine + 同步控制 #

要让多个函数向同一个channel发送数据，核心是让这些函数在独立的goroutine里运行，同时用同步机制确保所有发送操作完成后再安全关闭channel（避免接收端出错）。这里用sync.WaitGroup是最常用的方式：

package main

import (
    "fmt"
    "sync"
)

func main() {
    // 创建一个用于接收结果的channel
    resultChan := make(chan int)
    var wg sync.WaitGroup

    // 告诉WaitGroup我们要等待3个goroutine完成
    wg.Add(3)

    // 启动第一个修改函数的goroutine
    go func() {
        defer wg.Done() // 函数完成后标记WaitGroup的计数减1
        modify1(resultChan)
    }()

    // 启动第二个修改函数的goroutine
    go func() {
        defer wg.Done()
        modify2(resultChan)
    }()

    // 启动第三个修改函数的goroutine
    go func() {
        defer wg.Done()
        modify3(resultChan)
    }()

    // 单独启动一个goroutine，等待所有发送操作完成后关闭channel
    go func() {
        wg.Wait()
        close(resultChan)
    }()

    // 主goroutine负责接收channel里的所有数据
    for val := range resultChan {
        fmt.Println("收到结果:", val)
    }
}

// 模拟你的修改函数，向channel发送处理后的数据
func modify1(ch chan int) {
    ch <- 10 // 这里可以替换成你的业务逻辑
}

func modify2(ch chan int) {
    ch <- 20
}

func modify3(ch chan int) {
    ch <- 30
}

代码关键逻辑解释 #

1. 并发启动goroutine：每个modify函数都通过go关键字在独立的goroutine中运行，这样它们可以同时执行，不会互相阻塞。
2. WaitGroup同步：wg.Add(3)注册要等待的goroutine数量，每个goroutine结束前调用wg.Done()减少计数；wg.Wait()会阻塞直到所有计数归零，这时我们就可以安全关闭channel了——不会有goroutine再向已关闭的channel发送数据（否则会触发panic）。
3. 独立的关闭channel goroutine：如果在主goroutine里直接执行wg.Wait()，会导致主goroutine先阻塞，没法接收channel里的数据，所以单独开一个goroutine来处理等待和关闭操作，让主goroutine专注于接收。

额外小提示 #

• 如果你的修改函数处理时间不一，channel的接收顺序不一定和goroutine启动顺序一致，这是正常的并发特性。
• 如果希望channel能缓存部分数据，可以创建带缓冲的channel，比如make(chan int, 3)，这样发送端在缓冲区满之前不会阻塞，但同步逻辑还是需要的。

内容的提问来源于stack exchange，提问作者OneSockThief