Package org.nuxeo.ecm.core.storage
Class InvalidationsQueue<T extends SerializableAccumulableInvalidations>
- java.lang.Object
-
- org.nuxeo.ecm.core.storage.InvalidationsQueue<T>
-
- Type Parameters:
T- the invalidations type
- Direct Known Subclasses:
DBSInvalidationsQueue,VCSInvalidationsQueue
public abstract class InvalidationsQueue<T extends SerializableAccumulableInvalidations> extends Object
Queue of invalidations.All invalidations added are accumulated (from multiple threads), then returned when asked for.
- Since:
- 11.1
-
-
Constructor Summary
Constructors Constructor Description InvalidationsQueue(String name)
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description voidaddInvalidations(T invalidations)Adds invalidations.TgetInvalidations()Gets the queued invalidations and resets the queue.abstract TnewInvalidations()Constructs new empty invalidations, of typeInvalidationsQueue.StringtoString()
-
-
-
Field Detail
-
queue
public T extends SerializableAccumulableInvalidations queue
-
name
public final String name
used for debugging
-
-
Constructor Detail
-
InvalidationsQueue
public InvalidationsQueue(String name)
-
-
Method Detail
-
newInvalidations
public abstract T newInvalidations()
Constructs new empty invalidations, of typeInvalidationsQueue.
-
addInvalidations
public void addInvalidations(T invalidations)
Adds invalidations.May be called asynchronously from multiple threads.
-
getInvalidations
public T getInvalidations()
Gets the queued invalidations and resets the queue.
-
-