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 void
addInvalidations(T invalidations)
Adds invalidations.T
getInvalidations()
Gets the queued invalidations and resets the queue.abstract T
newInvalidations()
Constructs new empty invalidations, of typeInvalidationsQueue
.String
toString()
-
-
-
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.
-
-