Может есть какой-то готовый код, чтобы не изобретать велосипеды.
Сценарий такой. В коде генерируются некие обновления, которые затем обрабатываются неким методом. Обновления могут генерироваться слишком часто, плюс метод обработки может тормозить, в результате обновления не успевают обрабатываться, накапливаются, обработчик потом делает лишнюю работу. Хотелось бы как-то "накопить" обновления, пока обработчик занят. Причём, сами данные для обновления уже "накапливаются", об этом заботиться не нужно, нужно только разрулить "накопление" запросов к обработчику, чтобы когда обработчик освободиться обрабатывать не все накопившиеся запросы на обновление по отдельности, а за один раз сразу весь пакет "обновлений" обработать.
Как сейчас:
async Task UpdateFoo()
{
...
await SaveAsync();
}
async Task UpdateBar()
{
...
await SaveAsync();
}
async Task UpdateBaz()
{
...
await SaveAsync();
}
async Task SaveAsync()
{
// здесь нужно сделать так,
// чтобы одновременно обрабатывался только один запрос
// по окончании которого проверялось бы не было ли ещё запросов
// и если были, то обновление запускалось бы ещё один раз (сразу за всё "накопленное")
// и так пока есть обновления по окончании очередной обработки
}
Наверняка логика должна быть какая-то простая довольно, и сценарий довольно типовой, но не соображу, как нормально написать. Для того, чтобы зайти один раз - понятно, SemaphoreSlim
, видимо (с WaitAsync
). А вот остальное как лучше сделать?