Partager via


CachedMessageBlock Classe

Définition

CachedMessageBlock est un bloc de structures étroitement emballées contenant des données de suivi pour les messages mis en cache. Ces données sont étroitement emballées pour réduire la pression gc. Les données de suivi sont utilisées par le cache de file d’attente pour parcourir le cache qui sert les messages de file d’attente ordonnés par flux.

public class CachedMessageBlock : Orleans.Providers.Streams.Common.PooledResource<Orleans.Providers.Streams.Common.CachedMessageBlock>
type CachedMessageBlock = class
    inherit PooledResource<CachedMessageBlock>
Public Class CachedMessageBlock
Inherits PooledResource(Of CachedMessageBlock)
Héritage

Constructeurs

CachedMessageBlock(Int32)

Bloc de messages mis en cache.

Propriétés

HasCapacity

Obtient une valeur indiquant si d’autres messages peuvent être ajoutés au bloc.

IsEmpty

Obtient une valeur indiquant si ce bloc est vide.

Item[Int32]

Accédez au message mis en cache à l’index fourni.

ItemCount

Obtient le nombre de messages dans ce bloc.

NewestMessage

Obtient le message le plus récent de ce bloc.

NewestMessageIndex

Obtient l’index du message le plus récent ajouté au bloc.

Node

Nœud de liste liée, de sorte que ce bloc de messages peut être conservé dans une liste liée.

OldestMessage

Obtient le message le plus ancien du bloc.

OldestMessageIndex

Obtient l’index du message le plus ancien de ce bloc.

Pool

Obtient le pool vers lequel renvoyer cette ressource lors de sa suppression. Un pool doit définir cette propriété lors de l’allocation de ressources.

(Hérité de PooledResource<T>)

Méthodes

Add(CachedMessage)

Ajoutez un message de la file d’attente au bloc. Convertit le message de file d’attente en message mis en cache et le stocke à la fin du bloc.

Dispose()

Retourne l’élément au pool.

(Hérité de PooledResource<T>)
GetIndexOfFirstMessageLessThanOrEqualTo(StreamSequenceToken)

Obtient l’index du premier message de ce bloc qui a un jeton de séquence au niveau ou avant le jeton fourni

GetNewestSequenceToken(ICacheDataAdapter)

Obtient le jeton de séquence du message le plus récent de ce bloc

GetOldestSequenceToken(ICacheDataAdapter)

Obtient le jeton de séquence du message le plus ancien de ce bloc

GetSequenceToken(Int32, ICacheDataAdapter)

Obtient le jeton de séquence du message mis en cache à l’index fourni

OnResetState()

Réinitialise cet état de blocs à celui d’un bloc vide.

Remove()

Supprime un message au début du bloc (données les plus anciennes).

SignalPurge()

Si cet objet doit être utilisé dans un pool d’objets de taille fixe, cet appel doit être remplacé par l’implémentation de purge qui retourne l’objet au pool.

(Hérité de PooledResource<T>)
TryFindFirstMessage(IStreamIdentity, ICacheDataAdapter, Int32)

Tente de trouver le premier message dans le bloc qui fait partie du flux fourni.

TryFindFirstMessage(StreamId, ICacheDataAdapter, Int32)

Tente de trouver le premier message dans le bloc qui fait partie du flux fourni.

TryFindNextMessage(Int32, IStreamIdentity, ICacheDataAdapter, Int32)

Tente d’obtenir le message suivant à partir du flux fourni, en commençant par l’index de début.

TryFindNextMessage(Int32, StreamId, ICacheDataAdapter, Int32)

Tente d’obtenir le message suivant à partir du flux fourni, en commençant par l’index de début.

S’applique à