AS
А разве не должен прием блокироваться просто?
Size: a a a
2020 October 07
R
А разве не должен прием блокироваться просто?
https://play.golang.org/p/rCHAOxJZFjw наверно хотелось что-то типа этого?https://play.golang.org/p/rCHAOxJZFjw наверно хотелось что-то типа этого? это неправильно
AS
хотя если изменить так
c := make(chan int)то пример так же работает
go fibonacci(10, c)
AS
Господа, прошу помощи. Совсем запутался.
Пытаюсь запустить горутину, чтобы она ждала появления данных в канале.
Потом запускается чтение файла, где он парсится в mail.Message и отправляется в канал, где его должна ждать горутина.
Вроде делаю, как по написанному 🙂 (ну то есть прямо вот книжный пример взял
А в дебаге вижу, что range выполняется по пустому каналу, хотя, как я понял, такая конструкция в горутине должна блокироваться
Пытаюсь запустить горутину, чтобы она ждала появления данных в канале.
Потом запускается чтение файла, где он парсится в mail.Message и отправляется в канал, где его должна ждать горутина.
…
mailChan := make(chan *mail.Message)
go processMail(redis, mailChan)
for _, fileName := range fileNames {
err := ReadFile(mailChan, fileName)
if err !=nil {ololo}
}
close(mailChan)
…
func ReadFile(job chan<- *mailMessage, fileName string) (err error) {
file, err := os.Open(fileName)
…
m, err := mail.ReadMessage(file)
job <- m
}
func processMail(redis writer.ProcessRedis, in <-chan *mail.Message) {
for m := range in {
rcpt := strings.ToLower(m.Header.Get("X-Failed-Recipients"))
….
redis.Insert(record)
}
}
Вроде делаю, как по написанному 🙂 (ну то есть прямо вот книжный пример взял
for m := range in {А в дебаге вижу, что range выполняется по пустому каналу, хотя, как я понял, такая конструкция в горутине должна блокироваться
а что значит "выполняется по пустому каналу"?
Y
а что значит "выполняется по пустому каналу"?
Ну я в дебаггере вижу, что доходит выполнение до for , иногда проходит до
fmt.Printf("Chan length: %d", len(in)) на второй строке после for … range, дальше все завершаетсяY
Ни фига понять не могу
Y
пишет - ноль
Y
Блин… запускаю с
run -race - все работает, как надоAS
Ну я в дебаггере вижу, что доходит выполнение до for , иногда проходит до
fmt.Printf("Chan length: %d", len(in)) на второй строке после for … range, дальше все завершаетсяну, len(chan) - это , как я понимаю, только про буферизованный канал ))
Y
да неважно, на самом деле. Я больше, как индикатор это использую - дошло туда выполнение или нет
Y
странно… где-то гонку упускаю. Но где?
Y
Всем спасибо. Точно не учел, что main завершается раньше, чем горутина отработает
R
Всем спасибо. Точно не учел, что main завершается раньше, чем горутина отработает
ну скажи для людей, как исправил) как то так? https://play.golang.org/p/5IDcbKiIO3S
Y
ну скажи для людей, как исправил) как то так? https://play.golang.org/p/5IDcbKiIO3S
Ага. В точку )
MV
всем, привет. Подскажите плиз, где искать golang программиста? Ищу неделю, откликов совсем нет(
Заранее спасибо
Заранее спасибо
Y
Заблокировал main до получения сигнала от горутины «я вся готовая»
Y
всем, привет. Подскажите плиз, где искать golang программиста? Ищу неделю, откликов совсем нет(
Заранее спасибо
Заранее спасибо
Условия и вилка?
R
Заблокировал main до получения сигнала от горутины «я вся готовая»
сразу надо говорить скока денег)
MV
Условия и вилка?
Удаленка, до 250к рублей.
Y
Удаленка, до 250к рублей.
А где ищешь-то? В газете?