Есть система, которая выкидывает и исполняет события: type Event struct {

Question

Есть система, которая выкидывает и исполняет события: type Event struct {

Timestamp uint64
Type T
}
События должны где-то накапливаться. События могут быть запланированы как на через минуту, так и на через несколько миллисек
Есть воркер, который в 1й горутине:
1. выцепляет событие с наиближайшим timestamp
2. ждет положенное время
3. исполняет событие
4. пока воркер ждет, если пришло событие с timestamp ближе, воркер переключается на него, и кладет предыдущее событие обратно в хранилище.

Событий может быть от 10 до сотен в секунду. В очереди ждать могут до нескльких сот событий.

Подойдет ли для хранения событий heap ? Или есть лучше варианты?

Спасибо!

#backend #go #programming #russian

0

07.04.2021

7 ответов

10 просмотров

Ivan Pushkin Автор вопроса

О! А интересная идея, проверять раз в t минимальное значение timestamp из heap! Спасибо @derfenix !

0

07.04.2021

Andrey Burov

это задача с тестового задания?

0

07.04.2021

Ivan Pushkin Автор вопроса

Andrey Burov
это задача с тестового задания?

Неа, это мой pet проект

0

07.04.2021

Ivan Pushkin Автор вопроса

Andrey Burov
это задача с тестового задания?

Хотя не плохой был бы вопрос

0

07.04.2021

Andrey Burov

если !точно! известно что в очереди будет не много событий, то на каждое событие можно создавать time.Timer, и с помощью reflect.Select выбирать таймер, событие которого нужно выполнить

0

07.04.2021

Ivan Pushkin Автор вопроса

Andrey Burov
если !точно! известно что в очереди будет не много...

Спасибо!) ...пошел смотреть документацию reflect.Select...

0

07.04.2021

Sergey · Accepted Answer

Sergey

Я бы взял хип, да. И не брать и ждать, а раз в секунду получать минимальное значение из хипа и проверял, подошло ли время.

0

07.04.2021

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

Есть система, которая выкидывает и исполняет события: type Event struct {

7 ответов

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