Zum Hauptinhalt springen

Vom Queue-Anfang entnehmen (LCC.kvdb.queue.pop_front)

Deklaration​

value, err = LCC.kvdb.queue.pop_front(name, timeout?)
values, err = LCC.kvdb.queue.pop_front({name = name, max = n}, timeout?)

Parameter​

  • name String. Queue-Name (nicht leer, maximal 256 Byte). Für das Stapel-Entnehmen {name = "...", max = n} übergeben.
  • timeout
    Zahl, optional. Anfrage-Timeout in Sekunden, Standard 60.

Rückgabewerte​

  • value
    String. Vom Queue-Anfang entnommenes Element; nil, wenn die Queue leer ist.
  • values String-Array. Im Stapelmodus entfernte Elemente; {}, wenn die Queue leer ist.
  • err String oder nil. Im Einzelwertmodus wird bei leerer oder fehlender Queue 'not found' zurückgegeben.

Hinweise​

Entfernt das erste Element aus der Queue und gibt es zurück.
Der Stapelmodus gibt bis zu max Elemente in der tatsächlichen Entnahmereihenfolge zurück. Bei leerer Queue wird nil, 'not found' zurückgegeben.

Beispiel​

local value, err = LCC.kvdb.queue.pop_front("待处理任务")
if value then
    print("处理任务:", value)
end

local values, batch_err = LCC.kvdb.queue.pop_front({name = "待处理任务", max = 3})
for _, item in ipairs(values or {}) do
    print("处理任务:", item)
end