AS
Size: a a a
2020 April 17
AT
А есть пример с контекстом, как это будет использоваться
AT
*поменял ссылки на те который указывают точно на место где это нужно
AF
У меня есть некоторая логика с каналами
for { select { default: } }, где в default проверяется пул пользователей. Когда пул достигает нужного размера, отправляются сообщения, пул сбрасывается и так по for'у. Если в default я не выставлю time.Sleep, то ядро цп будет загружено на 100%. Вопрос: использование time.Sleep в данном случае оправдано или нужно переделывать архитектуру?AF
а как вы в пул добавляете?
case user := <-pool.register:
AF
а как вы в пул добавляете?
Т.е. я могу и под события переделать, но не знаю насколько сложно это будет и правильно ли
AT
Есть еще старая либа реализующая старую версию Wren'a
Там это реализовано просто, они возвращают reflect.Value
https://github.com/dradtke/go-wren/blob/50912fb5e4360c598fd989b4c30c0c556622a422/wren.go#L446
Там это реализовано просто, они возвращают reflect.Value
https://github.com/dradtke/go-wren/blob/50912fb5e4360c598fd989b4c30c0c556622a422/wren.go#L446
AT
Но хочется что-то элегантнее
а
case user := <-pool.register:
а зачем вам тогда default?
AF
а зачем вам тогда default?
pool.register не единственный, там еще есть "события". А в default я проверяю сам pool
AS
У меня есть некоторая логика с каналами
for { select { default: } }, где в default проверяется пул пользователей. Когда пул достигает нужного размера, отправляются сообщения, пул сбрасывается и так по for'у. Если в default я не выставлю time.Sleep, то ядро цп будет загружено на 100%. Вопрос: использование time.Sleep в данном случае оправдано или нужно переделывать архитектуру?если в case ничего не попадает - выполняется default в цикле - скорее всего что-то не то у вас...
AF
ну вообще тогда в селект её вынести проще
Тогда придется выносить проверку и в нескольких select'ах её вызывать... Но наверное это лучше, чем блокировать default
AS
Тогда придется выносить проверку и в нескольких select'ах её вызывать... Но наверное это лучше, чем блокировать default
заведите отдельный канал типа chan struct{} и пишите в него при добавлении пользователя, а сам канал добавьте в селект и по появлению данных проверяйте то, что делали в default
AF
заведите отдельный канал типа chan struct{} и пишите в него при добавлении пользователя, а сам канал добавьте в селект и по появлению данных проверяйте то, что делали в default
Спасибо!
AS
Спасибо!
канал естественно буферизированный...