для диапазона против статической длины канала

Question

У меня есть канал, принимающий события, проанализированные из файла журнала, и другой, который используется для синхронизации.Для моего теста было 8 событий.

При использовании синтаксиса for range я получаю 4 события.Используя известное число (8), я могу получить их все.

func TestParserManyOpinit(t *testing.T) {
    ch := make(chan event.Event, 1000)
    done := make(chan bool)
    go parser.Parse("./test_data/many_opinit", ch, done)
    count := 0
    exp := 8
    evtList := []event.Event{}

    <-done
    close(ch)
    //This gets all the events
    for i := 0; i < 8; i++ {
            evtList = append(evtList, <-ch)
            count++
    }

    //This only gives me four
    //for range ch {
    //        evtList = append(evtList, <-ch)
    //        count++
    //}

    if count != exp || count != len(evtList) {
            t.Errorf("Not proper lenght, got %d, exp %d, evtList %d", count, exp, len(evtList))
    }

func Parse(filePath string, evtChan chan event.Event, done chan bool) {
    log.Info(fmt.Sprintf("(thread) Parsing file %s", filePath))
    file, err := os.Open(filePath)
    defer file.Close()

    if err != nil {
            log.Error("Cannot read file " + filePath)
    }
    count := 0
    scan := bufio.NewScanner(file)
    scan.Split(splitFunc)
    scan.Scan() //Skip log file header

    for scan.Scan() {
            text := scan.Text()
            text = strings.Trim(text, "\n")
            splitEvt := strings.Split(text, "\n")
            // Some parsing ...
            count++
            evtChan <- evt
    }

    fmt.Println("Done ", count) // gives 8
    done <- true
}

Я, должно быть, упускаю что-то, связанное с циклами for на канале.

Я попытался добавитьtime.Sleep как раз перед done <- true частью.Это не изменило результат.

Answer 1

Когда вы используете for range, каждая итерация цикла читает из канала, а вы не используете значение чтения.Следовательно, половина значений отбрасывается.Оно должно быть:

for ev := range ch {
        evtList = append(evtList, ev)
        count++
}

Для фактического использования значений, считанных в итераторе цикла.

Ранжирование по каналам показано в Tour of Go и подробнов спецификации Go .