Package org.terracotta.statistics.archive

Class StatisticSampler<T extends java.io.Serializable>

java.lang.Object

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

public class StatisticSampler<T extends java.io.Serializable>
extends java.lang.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 java.io.Serializable>

Field Summary

Fields

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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
void	setPeriod(long time, java.util.concurrent.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 Detail

exclusiveExecutor

private final boolean exclusiveExecutor

executor

private final java.util.concurrent.ScheduledExecutorService executor

task

private final StatisticSampler.SamplingTask<T extends java.io.Serializable> task

currentExecution

private java.util.concurrent.ScheduledFuture<?> currentExecution

period

private long period

Constructor Detail

StatisticSampler

public StatisticSampler(long time,
                        java.util.concurrent.TimeUnit unit,
                        ValueStatistic<T> statistic,
                        java.util.function.Consumer<Sample<T>> sink,
                        java.util.function.LongSupplier timeSupplier)

StatisticSampler

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

Method Detail

setPeriod

public void setPeriod(long time,
                      java.util.concurrent.TimeUnit unit)

start

public void start()

stop

public void stop()

shutdown

public void shutdown()
              throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException