class WriteBehindQueue extends AbstractWriteBehindQueue
Modifier and Type | Field and Description |
---|---|
private java.util.List<SingleOperation> |
waiting |
Constructor and Description |
---|
WriteBehindQueue(CacheConfiguration config)
Construct a simple list backed write behind queue.
|
Modifier and Type | Method and Description |
---|---|
protected void |
addItem(SingleOperation operation)
Add an item to the write behind queue
|
long |
getQueueSize()
Gets the best estimate for items in the queue still awaiting processing.
|
protected java.util.List<SingleOperation> |
quarantineItems()
Quarantine items to be processed.
|
protected void |
reinsertUnprocessedItems(java.util.List<SingleOperation> operations)
Reinsert any unfinished operations into the queue.
|
delete, getProcessingThread, setOperationsFilter, start, stop, write
private java.util.List<SingleOperation> waiting
WriteBehindQueue(CacheConfiguration config)
config
- protected java.util.List<SingleOperation> quarantineItems()
AbstractWriteBehindQueue
quarantineItems
in class AbstractWriteBehindQueue
protected void addItem(SingleOperation operation)
AbstractWriteBehindQueue
addItem
in class AbstractWriteBehindQueue
operation
- operation to be donepublic long getQueueSize()
AbstractWriteBehindQueue
getQueueSize
in interface WriteBehind
getQueueSize
in class AbstractWriteBehindQueue
protected void reinsertUnprocessedItems(java.util.List<SingleOperation> operations)
AbstractWriteBehindQueue
reinsertUnprocessedItems
in class AbstractWriteBehindQueue
operations
- list of unfinished operations