Class StampedLockManager.Cache<T>

java.lang.Object

org.eclipse.rdf4j.common.concurrent.locks.StampedLockManager.Cache<T>

Enclosing class:

StampedLockManager

public static class StampedLockManager.Cache<T>
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	StampedLockManager.Cache.OptimisticState
class	StampedLockManager.Cache.ReadableState
class	StampedLockManager.Cache.WritableState

Field Summary

Fields

Modifier and Type	Field	Description
private T	data
private final Supplier<T>	dataSupplier
private final StampedLockManager	stampedLockManager

Constructor Summary

Constructors

Constructor	Description
Cache(StampedLockManager stampedLockManager, Supplier<T> dataSupplier)

Method Summary

Modifier and Type	Method	Description
StampedLockManager.Cache<T>.OptimisticState	getOptimisticState()
StampedLockManager.Cache<T>.ReadableState	getReadState()
StampedLockManager.Cache<T>.WritableState	getWriteState()
private void	refreshCacheIfNeeded()
private Lock	refreshCacheIfNeeded(Lock readLock)
void	warmUp()

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

dataSupplier

private final Supplier<T> dataSupplier

data

private volatile T data

stampedLockManager

private final StampedLockManager stampedLockManager

Constructor Details

Cache

public Cache(StampedLockManager stampedLockManager,
 Supplier<T> dataSupplier)

Method Details

getReadState

public StampedLockManager.Cache<T>.ReadableState getReadState()
                                                       throws InterruptedException

Throws:

InterruptedException

refreshCacheIfNeeded

private Lock refreshCacheIfNeeded(Lock readLock)
                           throws InterruptedException

Throws:

InterruptedException

refreshCacheIfNeeded

private void refreshCacheIfNeeded()
                           throws InterruptedException

Throws:

InterruptedException

getWriteState

public StampedLockManager.Cache<T>.WritableState getWriteState()
                                                        throws InterruptedException

Throws:

InterruptedException

getOptimisticState

public StampedLockManager.Cache<T>.OptimisticState getOptimisticState()
                                                               throws InterruptedException

Throws:

InterruptedException

warmUp

public void warmUp()
            throws InterruptedException

Throws:

InterruptedException