我創建了一個最小的可復制示例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 文件但永遠不會有數據。運行此程序時不會引發任何錯誤。我讀到我應該使用我已經實現的互斥鎖,但這也沒有奏效。我應該在這里做什么?
如何在 Go 中同時寫入兩個不同的 csv 文件?
ibeautiful
2022-10-10 18:10:33