Top Inners Fields Constructors Methods
org.terracotta.statistics.archive

public Class StatisticSampler<T extends java.io.Serializable>

extends Object
Class Inheritance
Imports
org.terracotta.statistics.Sample, .ValueStatistic, java.io.Serializable, java.util.concurrent.Executors, .ScheduledExecutorService, .ScheduledFuture, .ThreadFactory, .TimeUnit, java.util.function.Consumer, .LongSupplier
Author
cdennis

Nested and Inner Type Summary

Modifier and TypeClass and Description
pack-priv static class
StatisticSampler.SamplerThreadFactory

pack-priv static class
StatisticSampler.SamplingTask<T extends Serializable>

Field Summary

Modifier and TypeField and Description
private ScheduledFuture<?>
currentExecution

private final boolean
exclusiveExecutor

private final ScheduledExecutorService
executor

private long
period

private final StatisticSampler.SamplingTask<T>
task

Constructor Summary

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

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

Method Summary

Modifier and TypeMethod and Description
public synchronized void
setPeriod(long time, TimeUnit unit)

public synchronized void
shutdown()

public synchronized void
start()

public synchronized void
stop()

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

currentExecutionback to summary
private ScheduledFuture<?> currentExecution
exclusiveExecutorback to summary
private final boolean exclusiveExecutor
executorback to summary
private final ScheduledExecutorService executor
periodback to summary
private long period
taskback to summary
private final StatisticSampler.SamplingTask<T> task

Constructor Detail

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

Method Detail

setPeriodback to summary
public synchronized void setPeriod(long time, TimeUnit unit)
shutdownback to summary
public synchronized void shutdown() throws InterruptedException
startback to summary
public synchronized void start()
stopback to summary
public synchronized void stop()
org.terracotta.statistics.archive back to summary

pack-priv Class StatisticSampler.SamplerThreadFactory

extends Object
implements ThreadFactory
Class Inheritance
  • java.lang.Object
  • org.terracotta.statistics.archive.StatisticSampler.SamplerThreadFactory
All Implemented Interfaces
java.util.concurrent.ThreadFactory

Constructor Summary

AccessConstructor and Description
pack-priv
SamplerThreadFactory()

Method Summary

Modifier and TypeMethod and Description
public Thread
newThread(Runnable
a runnable to be executed by new thread instance
r)

Implements java.util.concurrent.ThreadFactory.newThread.

Constructs a new unstarted Thread to run the given runnable.
Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Constructor Detail

SamplerThreadFactoryback to summary
pack-priv SamplerThreadFactory()

Method Detail

newThreadback to summary
public Thread newThread(Runnable r)

Implements java.util.concurrent.ThreadFactory.newThread.

Doc from java.util.concurrent.ThreadFactory.newThread.

Constructs a new unstarted Thread to run the given runnable.

Parameters
r:Runnable

a runnable to be executed by new thread instance

Returns:Thread

constructed thread, or null if the request to create a thread is rejected

Annotations
@Override
org.terracotta.statistics.archive back to summary

pack-priv Class StatisticSampler.SamplingTask<T extends java.io.Serializable>

extends Object
implements Runnable
Class Inheritance
  • java.lang.Object
  • org.terracotta.statistics.archive.StatisticSampler.SamplingTask
All Implemented Interfaces
java.lang.Runnable

Field Summary

Modifier and TypeField and Description
private final Consumer<Sample<T>>
sink

private final ValueStatistic<T>
statistic

private final LongSupplier
timeSupplier

Constructor Summary

AccessConstructor and Description
pack-priv
SamplingTask(ValueStatistic<T> statistic, Consumer<Sample<T>> sink, LongSupplier timeSupplier)

Method Summary

Modifier and TypeMethod and Description
public void
run()

Implements java.lang.Runnable.run.

Runs this operation.
Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

sinkback to summary
private final Consumer<Sample<T>> sink
statisticback to summary
private final ValueStatistic<T> statistic
timeSupplierback to summary
private final LongSupplier timeSupplier

Constructor Detail

SamplingTaskback to summary
pack-priv SamplingTask(ValueStatistic<T> statistic, Consumer<Sample<T>> sink, LongSupplier timeSupplier)

Method Detail

runback to summary
public void run()

Implements java.lang.Runnable.run.

Doc from java.lang.Runnable.run.

Runs this operation.

Annotations
@Override