Golang: почему следующий фрагмент кода не записывается в файл?

Question

У меня есть следующая часть кода, которая не записывает никаких данных в файл log.txt. Я не понимаю, почему? Это не должно быть проблемой синхронизации, потому что я закрываю файл перед запуском любой процедуры go и открываю/закрываю файл внутри каждой процедуры.

package main 

import (
    "fmt" 
    "runtime" 
    "os" 
    "time" 
) 

func main() { 
    runtime.GOMAXPROCS(4) 

    f, _ := os.Create("./log.txt") 
    f.Close() 

    logCh := make(chan string, 50) 

    go func() { 
     for { 
      msg, ok := <- logCh 
      if ok { 
       logTime := time.Now().Format(time.RFC3339) 

       f, _ := os.OpenFile("./log.txt", os.O_APPEND, os.ModeAppend) 

       f.WriteString(logTime + " - " + msg) 

       f.Close() 

      } else { 
       break 
      } 
     } 
    }() 


    for i:=1; i < 10;i++ { 
     for j:=1; j<10;j++ { 
      go func(i, j int) { 
       msg := fmt.Sprintf("%d + %d = %d\n", i, j, i+j) 
       logCh <- msg 
       fmt.Print(msg) 
      }(i, j) 
     } 
    } 


    //fmt.Scanln() 
} 

Answer 1

Для этого вам нужно подождать, пока ваш канал не будет пуст. В этом случае вам также не нужен буферный канал. Используйте WaitGroup

Во-вторых, открытие и закрытие файла в каждой горуте, игнорируя ошибку, является актуальной проблемой. Вам не нужно открывать и закрывать файл каждый раз. Открывать один раз, синхронизировать после записи.

Это работает:

пакет главный

import (
    "fmt" 
    "os" 
    "runtime" 
    "sync" 
    "time" 
) 

func main() { 
    runtime.GOMAXPROCS(4) 

    f, _ := os.Create("./log.txt") 
    defer f.Close() 

    logCh := make(chan string) 
    var wg sync.WaitGroup 

    for i := 1; i < 10; i++ { 
     for j := 1; j < 10; j++ { 
      wg.Add(1) 
      go func(i, j int) { 
       defer wg.Done() 
       msg := fmt.Sprintf("%d + %d = %d\n", i, j, i+j) 
       logCh <- msg 
       fmt.Print(msg) 

      }(i, j) 
     } 
    } 

    go func() { 
     for { 
      msg, ok := <-logCh 
      if ok { 
       logTime := time.Now().Format(time.RFC3339) 

       f.WriteString(logTime + " - " + msg) 
       f.Sync() 

      } else { 
       break 
      } 
     } 
    }() 

    wg.Wait() 

    //fmt.Scanln() 
} 

Там также некоторые дополнительные данные в this question

Answer 2

два очевидных недостатков:

1. главная программа не ждать, пока другие goroutines, когда основная рутина возвращается, программа завершается, это почему log.txt пуст. sync.WaitGroup может быть полезно.

2. msg, ok := <- logCh, ok только false когда logCh закрыт и пуст. И вы не звоните close(logCh).