c
Minoru
я что-то не припомню там тем про сглаживание
я что-то не припомню там тем про сглаживание
Minoru
там было что-то про расчёт всяких средних и крайних случаев, типа сколько места отвести под очередь
Size: a a a
2021 October 28
c
Minoru
а в остальном считалось, что очередь обслуживается настолько быстро, насколько можно
а в остальном считалось, что очередь обслуживается настолько быстро, насколько можно
c
Minoru
а мне тут наоборот надо искусственно заставить «воркеры» простаивать
а мне тут наоборот надо искусственно заставить «воркеры» простаивать
c
Minoru
(я таким образом хочу снизить вероятность конфликтов за доступ к БД)
(я таким образом хочу снизить вероятность конфликтов за доступ к БД)
c
portnov
Minoru: все задания складывать в очередь, и из очереди выгребать по 1 сообщению в секунду?
Minoru: все задания складывать в очередь, и из очереди выгребать по 1 сообщению в секунду?
c
portnov
ну или там в миллисекунду
ну или там в миллисекунду
c
portnov
скорость выгребания можно, в принципе, адаптивно подбирать
скорость выгребания можно, в принципе, адаптивно подбирать
c
Minoru
да, я в эту же сторону думаю. Надеялся, что уже что-то придумали готовое и не придётся переизобретать колесо :)
да, я в эту же сторону думаю. Надеялся, что уже что-то придумали готовое и не придётся переизобретать колесо :)
c
Mr.Purple
debounce какой-то
debounce какой-то
c
Minoru
есть некоторое сходство, да. Но мне не нужно дедуплицировать сообщения, и нужно менять задержку в зависимости от количества сообщений
есть некоторое сходство, да. Но мне не нужно дедуплицировать сообщения, и нужно менять задержку в зависимости от количества сообщений
c
portnov
ну там тебе понадобится замерять текущее среднее время обработки одного задания
ну там тебе понадобится замерять текущее среднее время обработки одного задания
c
portnov
и от этого выбирать скорость выгребания из очереди
и от этого выбирать скорость выгребания из очереди
c
Minoru
нет, в моей задаче время обработки замерять не надо — я должен просто перестать читать входную очередь, чтобы на том конце сообразили, что система перегружена, и запустили ещё одного воркера
нет, в моей задаче время обработки замерять не надо — я должен просто перестать читать входную очередь, чтобы на том конце сообразили, что система перегружена, и запустили ещё одного воркера
c
portnov
а с той стороны видно, что ты перестал читать?
а с той стороны видно, что ты перестал читать?
c
portnov
может ты просто завален работой
может ты просто завален работой
c
Minoru
тут что-то похожее на thundering herd problem: когда приходит пачка заданий, воркеры тут же её разбирают и начинают работать, соревнуясь за общие ресурсы. И вот если задачки чуток задержать, то конфликтов между воркерами должно бы стать меньше
тут что-то похожее на thundering herd problem: когда приходит пачка заданий, воркеры тут же её разбирают и начинают работать, соревнуясь за общие ресурсы. И вот если задачки чуток задержать, то конфликтов между воркерами должно бы стать меньше
c
Minoru
portnov: видно. Сейчас у меня bounded channel, и когда в нём заканчивается место, попытка send() блокируется. Ну и, соответственно, есть try_send(), который позволяет той стороне проверить, что я ещё не завален, а если завален — как-то отреагировать
portnov: видно. Сейчас у меня bounded channel, и когда в нём заканчивается место, попытка send() блокируется. Ну и, соответственно, есть try_send(), который позволяет той стороне проверить, что я ещё не завален, а если завален — как-то отреагировать
t
всё интересенней и интересенней
t
появилась ТА сторона