Package org.terracotta.statistics.archive

Class StatisticSampler<T extends Serializable>

java.lang.Object

org.terracotta.statistics.archive.StatisticSampler<T>

public class StatisticSampler<T extends Serializable>
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static class	StatisticSampler.SamplerThreadFactory
(package private) static class	StatisticSampler.SamplingTask<T extends Serializable>

Field Summary

Fields

Modifier and Type	Field	Description
private ScheduledFuture<?>	currentExecution
private final boolean	exclusiveExecutor
private final ScheduledExecutorService	executor
private long	period
private final StatisticSampler.SamplingTask<T>	task

Constructor Summary

Constructors

Constructor	Description
StatisticSampler(long time, TimeUnit unit, ValueStatistic<T> statistic, Consumer<Sample<T>> sink, LongSupplier timeSupplier)
StatisticSampler(ScheduledExecutorService executor, long time, TimeUnit unit, ValueStatistic<T> statistic, Consumer<Sample<T>> sink, LongSupplier timeSupplier)

Method Summary

Modifier and Type	Method	Description
void	setPeriod(long time, TimeUnit unit)
void	shutdown()
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Field Details

exclusiveExecutor

private final boolean exclusiveExecutor

executor

private final ScheduledExecutorService executor

task

private final StatisticSampler.SamplingTask<T extends Serializable> task

currentExecution

private ScheduledFuture<?> currentExecution

period

private long period

Constructor Details

StatisticSampler

public StatisticSampler(long time,
 TimeUnit unit,
 ValueStatistic<T> statistic,
 Consumer<Sample<T>> sink,
 LongSupplier timeSupplier)

StatisticSampler

public StatisticSampler(ScheduledExecutorService executor,
 long time,
 TimeUnit unit,
 ValueStatistic<T> statistic,
 Consumer<Sample<T>> sink,
 LongSupplier timeSupplier)

Method Details

setPeriod

public void setPeriod(long time,
 TimeUnit unit)

start

public void start()

stop

public void stop()

shutdown

public void shutdown()
              throws InterruptedException

Throws:

InterruptedException