我創(chuàng)建了一個(gè)最小的可復(fù)制示例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        }    }}本質(zhì)上，我有兩個(gè)不同的服務(wù)，它們r(jià)ecord在兩個(gè)不同的 goroutine 中運(yùn)行一個(gè)方法。它們各自在不同時(shí)間創(chuàng)建并寫入不同的 csv 文件。當(dāng)我運(yùn)行它時(shí)，會創(chuàng)建 csv 文件但永遠(yuǎn)不會有數(shù)據(jù)。運(yùn)行此程序時(shí)不會引發(fā)任何錯誤。我讀到我應(yīng)該使用我已經(jīng)實(shí)現(xiàn)的互斥鎖，但這也沒有奏效。我應(yīng)該在這里做什么？