AU
но может проще самому набросать
Size: a a a
2021 November 25
AT
а сколько данных набежит в самом плохом сценарии за минимальный промежуток таймаута? какова вероятность набрать такую пачку, которая не заинсертиться да следующего таймаута?
TS
java.util.concurrent.DelayQueue
AU
вот конкретно этот метод как раз и делает то что тебе надо, если я правильно понял
TS
+
ES
ну вот сейчас у нас получается прилетает примерно 10-15 пакетов в секунду, то есть выполняется 10-15 инсертов того что лежит в пакетах, и мы уже ловим какое-то странное поведение CH, поэтому вот надо попробовать механизм чтобы один insert был в секунду
ES
ну и в пакете сейчас до 1000 евентов
ES
в общем пакеты надо еще раз спакетировать
AU
flatmap?
AU
rx еще норм обработку ошибок даст, но надо его тянуть
AU
без rx проще всего сделать executor в один тред, и сделать бин с Async аннотацией под этот конкретный executor и слать в него все пакеты
AU
оно немного не то и этот функционал давно выпилили оттуда
AU
в гуаве отдельный класс для кэшей
AU
в общем да, или смотри в сторону rx - flatmap + buffer делает именно то что ты хочешь
или советую Async + single thread executor + Scheduled
или советую Async + single thread executor + Scheduled
AU
это кэш, он делает немного нет то
ДД
AU
ну то есть ты можешь конечно просто все класть в кэш с рандомными ключами и он будет вызывать removalListener по expiration
AU
но это тебе никак не поможет с батчингом же
AU
это все равно что в js делать setTimeout() для каждого элемента