Пакетное удаление по значению (LCC.kvdb.queue.pop_values)
Сигнатура
count, err = LCC.kvdb.queue.pop_values(name, value, timeout?)
Параметры
- name
Строка, имя очереди (непустое, максимум256байт) - value
Строка, значение для поиска и удаления (должно быть корректным UTF-8) - timeout
Число, необязательный тайм-аут запроса (секунды), по умолчанию60
Возвращаемое значение
- count
Число, количество удалённых элементов; при сбое —nil - err
Строка илиnil, описание ошибки при сбое
Описание
Атомарно удаляет из очереди все элементы с указанным значением.
Возвращаемое значение — количество элементов, удалённых этим вызовом.
Пример
local removed, err = LCC.kvdb.queue.pop_values("待处理", "timeout")
if removed then
LCC.log(2, "清理异常任务", removed)
end