Engine-Klasse
MemoryStoreQueue
*Dieser Inhalt wurde mit KI (Beta) übersetzt und kann Fehler enthalten. Um diese Seite auf Englisch zu sehen, klicke hier.
Zusammenfassung
Methoden
GetSizeAsync(excludeInvisible: boolean):number |
RemoveAsync(id: string):() |
API-Referenz
Methoden
AddAsync
GetSizeAsync
ReadAsync
Rückgaben
Code-Beispiele
Verwenden einer MemoryStoreQueue
local MemoryStoreService = game:GetService("MemoryStoreService")
local DataStoreService = game:GetService("DataStoreService")
local queue = MemoryStoreService:GetQueue("PlayerQueue")
local dataStore = DataStoreService:GetDataStore("PlayerStore")
while true do
pcall(function()
-- warte auf ein Element zur Verarbeitung
local items, id = queue:ReadAsync(1, false, 30)
-- prüfe, ob ein Element abgerufen wurde
if #items > 0 then
-- markiere das Element als verarbeitet
dataStore:UpdateAsync(items[0], function(data)
data = data or {}
data.processed = 1
return data
end)
-- entferne das Element aus der Warteschlange
queue:RemoveAsync(id)
end
end)
endRemoveAsync
Parameter
Rückgaben
()
Code-Beispiele
Verwenden einer MemoryStoreQueue
local MemoryStoreService = game:GetService("MemoryStoreService")
local DataStoreService = game:GetService("DataStoreService")
local queue = MemoryStoreService:GetQueue("PlayerQueue")
local dataStore = DataStoreService:GetDataStore("PlayerStore")
while true do
pcall(function()
-- warte auf ein Element zur Verarbeitung
local items, id = queue:ReadAsync(1, false, 30)
-- prüfe, ob ein Element abgerufen wurde
if #items > 0 then
-- markiere das Element als verarbeitet
dataStore:UpdateAsync(items[0], function(data)
data = data or {}
data.processed = 1
return data
end)
-- entferne das Element aus der Warteschlange
queue:RemoveAsync(id)
end
end)
end