Package org.apache.cassandra.utils

Class RecomputingSupplier<T>

java.lang.Object

org.apache.cassandra.utils.RecomputingSupplier<T>

public class RecomputingSupplier<T>
extends Object

Supplier that caches the last computed value until it is reset, forcing every caller of get(long, TimeUnit) to wait until this value is computed if it was not computed yet. Calling recompute() won't reset value for the already waiting consumers, but instead will schedule one recomputation as soon as current one is done.

Constructor Summary

Constructors

Constructor	Description
RecomputingSupplier(Supplier<T> supplier, ExecutorService executor)

Method Summary

Modifier and Type	Method	Description
T	get(long timeout, TimeUnit timeUnit)
void	recompute()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Details

RecomputingSupplier

public RecomputingSupplier(Supplier<T> supplier,
 ExecutorService executor)

Method Details

recompute

public void recompute()

get

public T get(long timeout,
 TimeUnit timeUnit)
      throws InterruptedException,
ExecutionException,
TimeoutException

Throws:

InterruptedException

ExecutionException

TimeoutException

toString

public String toString()

Overrides:

toString in class Object