MemoryStoreQueue

Mostrar obsoleto

*Este contenido se traduce usando la IA (Beta) y puede contener errores. Para ver esta página en inglés, haz clic en aquí.

No creable
No replicado

Proporciona acceso a una cola dentro de MemoryStore.Una cola es una estructura de datos que proporciona almacenamiento temporal para elementos arbitrarios (hasta el tamaño máximo de elemento -- ver límites de almacenamiento de memoria ).Cada elemento de cola tiene una prioridad numérica: MemoryStore recupera primero los elementos con mayor prioridad de la cola, y recupera los elementos con la misma prioridad en orden de adición.

Los elementos en la cola se pueden configurar opcionalmente para expirar después de cierta cantidad de tiempo.Los elementos expirados simplemente desaparecen de la cola como si nunca se hubieran agregado.

Resumen

Métodos

Ver todos los heredados de Instance
Ver todos los heredados de Object

Propiedades

Ver todos los heredados de Instance
Ver todos los heredados de Object

Métodos

AddAsync

()
Proporciona

Añade un artículo a la cola.

Parámetros

value: Variant

El valor del artículo para agregar a la cola.

Valor predeterminado: ""
expiration: number

Tiempo de expiración del artículo, en segundos, después del cual el artículo se eliminará automáticamente de la cola.

Valor predeterminado: ""
priority: number

Prioridad de elemento. Los elementos con mayor prioridad se recuperan de la cola antes que los elementos con menor prioridad.

Valor predeterminado: 0

Devuelve

()

ReadAsync

Tuple
Proporciona

Lee uno o más elementos de la cola como una sola operación atómica.

Este método no elimina automáticamente los elementos devueltos de la cola, sino que los hace invisibles para otras llamadas de Lectura simultánea durante el período de tiempo de expiración de invisibilidad.Los elementos deben ser eliminados explícitamente de la cola con MemoryStoreQueue:RemoveAsync() antes de que expire el tiempo de inactividad de invisibilidad.La desactivación del tiempo de invisibilidad se establece por defecto en 30 segundos a menos que se proporcione un valor diferente en MemoryStoreService:GetQueue() .

Parámetros

count: number

Número de artículos para leído. El valor máximo permitido de este parámetro es 100.

Valor predeterminado: ""
allOrNothing: boolean

Controla el comportamiento del método en el caso de que la cola tenga menos de count artículos: si se establece en falso, el método devuelve todos los artículos disponibles; si se establece en verdad, no devuelve artículos.El valor predeterminado es falso.

Valor predeterminado: false
waitTimeout: number

La duración, en segundos, para la cual el método esperará si el número requerido de artículos no está disponible inmediatamente en la cola.Las lecturas se intentan cada segundo durante este período.Este parámetro se puede establecer en cero para indicar que no hay espera.Si este parámetro no se proporciona o se establece en -1, el método esperará indefinidamente.

Valor predeterminado: -1

Devuelve

Tuple

Un tuple de dos elementos.El primer elemento es un array de valores de artículo leídos de la cola.El segundo elemento es un identificador de cadena que debe pasarse a MemoryStoreQueue:RemoveAsync() para eliminar permanentemente estos elementos de la cola.

Muestras de código

The following code sample demonstrates using MemoryStoreQueue:ReadAsync() and MemoryStoreQueue:RemoveAsync() to reliably read, process, and remove items from a queue. Though this process can be as complicated as necessary, this example simply sets a flag in the corresponding data store item, which guarantees that every item will eventually be processed even if some of the calls encounter errors or the server crashes:

Depending on where the failure happens, it's possible that an item will be processed more than once. You should account for that like the following code sample, in which the end result is the same even if DataStoreService:UpdateAsync() is invoked multiple times.

Using a 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()

		-- wait for an item to process

		local items, id = queue:ReadAsync(1, false, 30)



		-- check if an item was retrieved

		if #items > 0 then

			-- mark the item as processed

			dataStore:UpdateAsync(items[0], function(data)

				data = data or {}

				data.processed = 1

				return data

			end)



			-- remove the item from the queue

			queue:RemoveAsync(id)

		end

	end)

end

RemoveAsync

()
Proporciona

Elimina un artículo o artículos previamente leídos de la cola.Este método utiliza el identificador devuelto por MemoryStoreQueue:ReadAsync() para identificar los elementos a eliminar.Si se llama después de que haya expirado el tiempo de inactividad de invisibilidad, la llamada no tiene efecto.

Parámetros

id: string

Identifica los elementos para eliminar. Usa el valor devuelto por MemoryStoreQueue:ReadAsync().

Valor predeterminado: ""

Devuelve

()

Muestras de código

The following code sample demonstrates using MemoryStoreQueue:ReadAsync() and MemoryStoreQueue:RemoveAsync() to reliably read, process, and remove items from a queue. Though this process can be as complicated as necessary, this example simply sets a flag in the corresponding data store item, which guarantees that every item will eventually be processed even if some of the calls encounter errors or the server crashes:

Depending on where the failure happens, it's possible that an item will be processed more than once. You should account for that like the following code sample, in which the end result is the same even if DataStoreService:UpdateAsync() is invoked multiple times.

Using a 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()

		-- wait for an item to process

		local items, id = queue:ReadAsync(1, false, 30)



		-- check if an item was retrieved

		if #items > 0 then

			-- mark the item as processed

			dataStore:UpdateAsync(items[0], function(data)

				data = data or {}

				data.processed = 1

				return data

			end)



			-- remove the item from the queue

			queue:RemoveAsync(id)

		end

	end)

end
Ver todos los heredados de Instance
Ver todos los heredados de Object

Eventos

Ver todos los heredados de Instance
Ver todos los heredados de Object