Tasks := make(chan *worker.Task) go func() { scanner := bufio.NewScanner(file)

Question

Tasks := make(chan *worker.Task) go func() { scanner := bufio.NewScanner(file)

for scanner.Scan() {
select {
case <-ctx.Done():
log.Infoln("signal cancel")
break
default:
// тут что-то делаем
}
}
if err := scanner.Err(); err != nil && err != io.EOF {
log.Errorln(err)
}
close(tasks)
}()

подскажите, почему не прерывается цикл сканера при завершении контекста?
весь цикл все равно пробегается до конца и выполняется только вывод лога "signal cancel" по количеству строчек в сканере

#backend #go #programming #russian

0

01.07.2020

1 ответов

21 просмотр

Roman · Accepted Answer

Roman

Добавьте 'label' к вашему for. И прерывайте его LOOP: for{ select { ...... break LOOP

0

01.07.2020

170 похожих чатов

Tasks := make(chan *worker.Task) go func() { scanner := bufio.NewScanner(file)

1 ответов

Похожие вопросы