А может кто-нибудь объяснить как for-select работает? Смотрю код в

Question

А может кто-нибудь объяснить как for-select работает? Смотрю код в

опенсорс проекте и не понимаю зачем нужен бесконечный for. Чел на мой вопрос пишет: "because it's infinite loop it needs to check internalQueue channels until timeout occurs"

ch := make(chan bool)
t := time.AfterFunc(timeout, func() { ch <- false })
defer func() {
t.Stop()
close(ch)
}()
for {
select {
case queue <- job:
return true
case <-ch:
return false
}
}

А я не понимаю чем это не угодило
select {
case queue <- job:
return true
case <-time.After(timeout):
return false
}

#backend #go #programming #russian

0

04.08.2021

6 ответов

10 просмотров

Alexey Palazhchenko

Yaroslav
Выглядит так что for здесь не нужен

Точно не нужен

0

04.08.2021

d. one-man

это какой опенсорс?

0

04.08.2021

Andrei Yangabishev Автор вопроса

d. one-man
это какой опенсорс?

https://github.com/ahmetask/worker/blob/master/dispatcher.go#L112 шедулер задач нужен был, нашел простенькую, а там такой код, засомневался в собственных знаниях

0

04.08.2021

💸osnull💘

Andrei Yangabishev
https://github.com/ahmetask/worker/blob/master/dis...

Поймал панику. panic: send on closed channel goroutine 33 [running]: github.com/ahmetask/worker.(*Pool).EnqueueWithTimeout.func1() /root/go/src/github com/ahmetask/worker/dispatcher.go:106 +0x36 created by time.goFunc /usr/local/go/src/time/sleep.go:166 +0x45

0

05.08.2021

Alexey Palazhchenko

💸osnull💘
Поймал панику. panic: send on closed channel gor...

Там гонка в коде между срабатыванием таймера его остановкой. Не используйте такую библиотеку 🙂

0

05.08.2021

Yaroslav · Accepted Answer

Yaroslav

Выглядит так что for здесь не нужен

0

04.08.2021

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

А может кто-нибудь объяснить как for-select работает? Смотрю код в

6 ответов

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