Вот смотрю язык, нраица. Только вот не понял, а как сделать

Question

Вот смотрю язык, нраица. Только вот не понял, а как сделать

такую штуку

Есть канал. У канала 1 воркер, несколько отправителей

Есть воркер-горутина. Он слушает канал. Дабы не потреблять в for-select-case-default много ресурсов cpu, и не костылить со Sleep в дефолте, пока из канали не придёт сообщение, воркер ждёт. Читай — заблокирован в for-select-case

Есть много горутин-отправителей, у них есть ссылка на канал, горутины-отправители могут просыпаться в любой момент.

Вопрос прост — почему я не могу сделать так, чтобы у меня крутился forever воркер и хендлил сообщения в канале от sender’ов? Сплошные дедлоки…

#backend #go #programming #russian

0

17.07.2021

15 ответов

22 просмотра

𝖁𝖎𝖙𝖆𝖑𝖎𝖞 𝕾 Автор вопроса

В эрланге проще. Там воркеры-gen_server по умолчанию заблокированы без сообщений и слушают “почтовый ящик”

0

17.07.2021

𝖁𝖎𝖙𝖆𝖑𝖎𝖞 𝕾 Автор вопроса

Евгений Омельченко
А код можно? Или репродьюс. Желательно на play.gol...

Ща накатаю. Код был где-то.

0

17.07.2021

Евгений Омельченко

𝖁𝖎𝖙𝖆𝖑𝖎𝖞 𝕾
В эрланге проще. Там воркеры-gen_server по умолчан...

Вообще если вы в форе слушаете канал, в селекте без дефолта или в явной форме (a := <- ch), то он будет заблокирован пока не появится данных

0

17.07.2021

𝖁𝖎𝖙𝖆𝖑𝖎𝖞 𝕾 Автор вопроса

Евгений Омельченко
Вообще если вы в форе слушаете канал, в селекте бе...

Ща, тогда просто попробую запустить слушалку (playground скину)

0

17.07.2021

𝖁𝖎𝖙𝖆𝖑𝖎𝖞 𝕾 Автор вопроса

Евгений Омельченко
Вообще если вы в форе слушаете канал, в селекте бе...

Да, это работает https://play.golang.org/p/Ot8lDcFh1mB

0

17.07.2021

𝖁𝖎𝖙𝖆𝖑𝖎𝖞 𝕾 Автор вопроса

Евгений Омельченко
Вообще если вы в форе слушаете канал, в селекте бе...

Ща буду воркеров добавлять, покажу.

0

17.07.2021

Мерль

А кто мешает просто заблокироваться на чтении из канала? Типа for { select { case task := <- tasks: // do tasks case <-ctx.Done() } }

0

17.07.2021

𝖁𝖎𝖙𝖆𝖑𝖎𝖞 𝕾 Автор вопроса

Мерль
А кто мешает просто заблокироваться на чтении из к...

🤔 изучу

0

17.07.2021

Мерль

𝖁𝖎𝖙𝖆𝖑𝖎𝖞 𝕾
🤔 изучу

https://tour.golang.org/welcome/1 https://gobyexample.com/

0

17.07.2021

𝖁𝖎𝖙𝖆𝖑𝖎𝖞 𝕾 Автор вопроса

Евгений Омельченко
Вообще если вы в форе слушаете канал, в селекте бе...

Дико извиняюсь. Не могу воспроизвести. Вчера мог воспроизвести, сейчас код с нуля написал (не сохранилось, как оказалось), и проблемы не возникло. worker висит, ждёт, отрабатывает сообщения жобы отправляют в канал сообщения WaitGroup нормально отрабатывает. 😅

0

17.07.2021

Евгений Омельченко

Ещё советую for range, если канал один

0

17.07.2021

𝖁𝖎𝖙𝖆𝖑𝖎𝖞 𝕾 Автор вопроса

Евгений Омельченко
Ещё советую for range, если канал один

Вот сейчас с ним ещё проверю.

0

17.07.2021

𝖁𝖎𝖙𝖆𝖑𝖎𝖞 𝕾 Автор вопроса

Евгений Омельченко
Ещё советую for range, если канал один

Баг попався! https://play.golang.org/p/RoN1qVP86j9 Как я понял, проблема том, что for range {} ждёт сообшения из незакрытого канала, в который никто никогда не напишет. Но как закрыть канал, если отправителей много?

0

17.07.2021

𝖁𝖎𝖙𝖆𝖑𝖎𝖞 𝕾 Автор вопроса

𝖁𝖎𝖙𝖆𝖑𝖎𝖞 𝕾
Баг попався! https://play.golang.org/p/RoN1qVP86j...

func readSeconds рудимент. Пардон муа … =(

0

17.07.2021

Евгений Омельченко · Accepted Answer

Евгений Омельченко

А код можно? Или репродьюс. Желательно на play.golang.org

0

17.07.2021

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

Вот смотрю язык, нраица. Только вот не понял, а как сделать

15 ответов

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