亚洲在线久爱草,狠狠天天香蕉网,天天搞日日干久草,伊人亚洲日本欧美

為了賬號安全,請及時綁定郵箱和手機立即綁定
已解決430363個問題,去搜搜看,總會有你想問的

如何在 Go 中同時寫入兩個不同的 csv 文件?

如何在 Go 中同時寫入兩個不同的 csv 文件?

Go
ibeautiful 2022-10-10 18:10:33
我創建了一個最小的可復制示例package mainimport (    "encoding/csv"    "fmt"    "os"    "strconv"    "sync/atomic"    "time")var (    csvOnePath = "test.csv"    csvTwoPath = "test_two.csv")type A struct {    Running     int32 // used atomically    QuitChan    chan struct{}}func NewA() *A {    return &A{        QuitChan: make(chan struct{}),    }}func (a *A) Start() error {    if ok := atomic.CompareAndSwapInt32(&a.Running, 0, 1); !ok {        return fmt.Errorf("Cannot start service A: service already started")    }    go a.record()    return nil}func (a *A) Stop() error {    if ok := atomic.CompareAndSwapInt32(&a.Running, 1, 0); !ok {        return fmt.Errorf("Cannot stop service A: service already stopped")    }    close(a.QuitChan)    return nil}func (a *A) record() {    //file_one, err := os.OpenFile(csvOnePath, os.O_APPEND|os.O_CREATE|os.O_WRONLY, 0755)    file_one, err := os.Create(csvOnePath)    if err != nil {        fmt.Println(err)        return    }    writer := csv.NewWriter(file_one)    // writer, closeFileFunc, err := NewCsvWriter(csvOnePath)    if err != nil {        fmt.Println(err)        return    }    header := []string{"this", "is", "a", "test"}    err = writer.Write(header)    if err != nil {        fmt.Println(err)        return    }    ticker := time.NewTicker(10*time.Second)    for {        select {        case t := <-ticker.C:            err = writer.Write([]string{fmt.Sprintf("%2d:%2d:%2d", t.Hour(), t.Minute(), t.Second())})            if err != nil {                fmt.Println(err)                a.QuitChan <- struct{}{}            }        case <-a.QuitChan:            ticker.Stop()            writer.Flush()            file_one.Close()            fmt.Println("Stopped recording.")            break        }    }}本質上,我有兩個不同的服務,它們record在兩個不同的 goroutine 中運行一個方法。它們各自在不同時間創建并寫入不同的 csv 文件。當我運行它時,會創建 csv 文件但永遠不會有數據。運行此程序時不會引發任何錯誤。我讀到我應該使用我已經實現的互斥鎖,但這也沒有奏效。我應該在這里做什么?
查看完整描述

1 回答

?
holdtom

TA貢獻1805條經驗 獲得超10個贊

如評論中所述,程序將在main()完成后退出;規范聲明“它不會等待其他(非主)goroutines 完成?!?。

這意味著您的 go 例程不太可能處理關閉文件的代碼,這意味著可能不會寫入緩沖數據。

我在操場上創建了您的應用程序的簡化版本來演示這一點。

有很多方法可以解決這個問題,但最簡單的可能是添加一個WaitGroup,這樣您的應用程序就可以在終止之前等待 go 例程退出。


查看完整回答
反對 回復 2022-10-10
  • 1 回答
  • 0 關注
  • 103 瀏覽
慕課專欄
更多

添加回答

舉報

0/150
提交
取消
微信客服

購課補貼
聯系客服咨詢優惠詳情

幫助反饋 APP下載

慕課網APP
您的移動學習伙伴

公眾號

掃描二維碼
關注慕課網微信公眾號