Перейти к основному содержимому

Пакетное удаление по значению (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