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()
		-- 等待处理一个项目
		local items, id = queue:ReadAsync(1, false, 30)

		-- 检查是否检索到项目
		if #items > 0 then
			-- 将项目标记为已处理
			dataStore:UpdateAsync(items[0], function(data)
				data = data or {}
				data.processed = 1
				return data
			end)

			-- 从队列中移除项目
			queue:RemoveAsync(id)
		end
	end)
end

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()
		-- 等待处理一个项目
		local items, id = queue:ReadAsync(1, false, 30)

		-- 检查是否检索到项目
		if #items > 0 then
			-- 将项目标记为已处理
			dataStore:UpdateAsync(items[0], function(data)
				data = data or {}
				data.processed = 1
				return data
			end)

			-- 从队列中移除项目
			queue:RemoveAsync(id)
		end
	end)
end