Go 中 goroutine 未执行完成导致通道数据丢失的典型问题解析-Golang-PHP中文网

Go 中 goroutine 未执行完成导致通道数据丢失的典型问题解析

go 程序在 main 函数返回时立即终止，不会等待已启动的 goroutine 完成；若未同步控制主协程退出时机，向通道发送的数据可能因程序提前退出而无法被消费。

go 程序在 main 函数返回时立即终止，不会等待已启动的 goroutine 完成；若未同步控制主协程退出时机，向通道发送的数据可能因程序提前退出而无法被消费。

你遇到的“单个设备不写入文件，两个设备才生效”的现象，并非通道行为异常，而是典型的 程序过早退出 问题。

在你的代码中：

func main() {
    deviceChan := make(chan *models.Device)
    go WriteDeviceToFile(deviceChan, "notalive.txt") // 启动 goroutine
    d := models.NewDevice("12346", "")
    deviceChan <p><code>main</code> 函数执行完 <code>close(deviceChan)</code> 后即返回，Go 运行时会强制终止所有正在运行的 goroutine（包括 <code>WriteDeviceToFile</code>），无论它是否已完成循环或写入操作。当只发送一个设备时，<code>WriteDeviceToFile</code> 可能刚进入 <code>for device := range d</code> 循环、甚至尚未执行 <code>json.Marshal</code> 就被中断；而发送两个设备时，只是“运气好”——程序恰好在第二个设备写入后、<code>main</code> 返回前完成了部分逻辑，但这<strong>不可靠、非确定性，绝非正确行为</strong>。</p><p>✅ 正确做法：使用同步机制确保 <code>main</code> 等待 goroutine 完成。推荐使用 <code>sync.WaitGroup</code>：</p><div class="aritcle_card flexRow artxards">
											<div class="artcardd flexRow">
												<a class="aritcle_card_img" rel="nofollow" href="/ai/2892" title="Prompt Log"><img
														src="https://img.php.cn/upload/ai_manual/001/246/273/177985622821242.png" alt="Prompt Log" onerror="this.onerror='';this.src='/static/lhimages/moren/morentu.png'" ></a>
												<div class="aritcle_card_info flexColumn">
													<a rel="nofollow" href="/ai/2892" title="Prompt Log" class="overflowclass">Prompt Log</a>
													<p class="overflowclass">一款AI开发辅助工具，主要用于从 AI 编程会话日志（Clawdbot、Claude Code、Codex）中提取对话记录。该功能用于在用户要求导出提示词历史、会话日志或 `.jsonl` 格式的会话文件时使用，适合需要提升相关任务效率的用户。</p>
												</div>
												<a rel="nofollow" href="/ai/2892" title="Prompt Log" class="aritcle_card_btn flexRow flexcenter"><b></b><span>下载</span>
												</a>
											</div>
										</div><pre class="brush:php;toolbar:false;">package main

import (
    "encoding/json"
    "fmt"
    "os"
    "path/filepath"
    "runtime"
    "sync"
    "/something/models"
)

func WriteDeviceToFile(d chan *models.Device, fileName string, wg *sync.WaitGroup) {
    defer wg.Done() // 标记 goroutine 完成

    _, b, _, _ := runtime.Caller(0)
    basepath := filepath.Dir(b)
    filePath := basepath + "/dataFile/" + fileName

    f, err := os.OpenFile(filePath, os.O_APPEND|os.O_WRONLY, 0600)
    if err != nil {
        panic(fmt.Sprintf("failed to open file: %v", err))
    }
    defer f.Close() // 注意：defer 在函数返回时执行，此处安全

    for device := range d {
        deviceB, err := json.Marshal(device)
        if err != nil {
            panic(fmt.Sprintf("JSON marshal failed: %v", err))
        }
        fmt.Println(string(deviceB))
        if _, err = f.WriteString(string(deviceB) + "\n"); err != nil {
            panic(fmt.Sprintf("write to file failed: %v", err))
        }
    }
}

func main() {
    deviceChan := make(chan *models.Device)
    var wg sync.WaitGroup
    wg.Add(1)
    go WriteDeviceToFile(deviceChan, "notalive.txt", &wg)

    d := models.NewDevice("12346", "")
    deviceChan <p>? 关键修复点：</p>