SingleThreadSchedulerStatisticTracker (threadly 6.2 API)

java.lang.Object
- org.threadly.concurrent.AbstractSubmitterExecutor
- - org.threadly.concurrent.AbstractSubmitterScheduler
  - - org.threadly.concurrent.AbstractPriorityScheduler
    - - org.threadly.concurrent.SingleThreadScheduler
      - org.threadly.concurrent.statistics.SingleThreadSchedulerStatisticTracker

All Implemented Interfaces:

java.util.concurrent.Executor, PrioritySchedulerService, SchedulerService, StatisticExecutor, StatisticPriorityScheduler, SubmitterExecutor, SubmitterScheduler
```
public class SingleThreadSchedulerStatisticTracker
extends SingleThreadScheduler
implements StatisticPriorityScheduler
```
An implementation of SingleThreadScheduler which tracks run and usage statistics. This is designed for testing and troubleshooting. It has a little more overhead from the normal SingleThreadScheduler.
It helps give insight in how long tasks are running, how well the thread pool is being utilized, as well as execution frequency.

Since:

4.5.0 (earlier forms existed since 1.0.0)

Constructor Summary

Constructors
Constructor and Description
`SingleThreadSchedulerStatisticTracker()` Constructs a new `SingleThreadScheduler`.
`SingleThreadSchedulerStatisticTracker(boolean daemonThread)` Constructs a new `SingleThreadScheduler`.
`SingleThreadSchedulerStatisticTracker(boolean daemonThread, int maxStatisticWindowSize)` Constructs a new `SingleThreadScheduler`.
`SingleThreadSchedulerStatisticTracker(boolean daemonThread, int maxStatisticWindowSize, boolean accurateTime)` Constructs a new `SingleThreadScheduler`.
`SingleThreadSchedulerStatisticTracker(int maxStatisticWindowSize)` Constructs a new `SingleThreadScheduler`.
`SingleThreadSchedulerStatisticTracker(int maxStatisticWindowSize, boolean accurateTime)` Constructs a new `SingleThreadScheduler`.
`SingleThreadSchedulerStatisticTracker(TaskPriority defaultPriority, long maxWaitForLowPriorityInMs)` Constructs a new `SingleThreadScheduler`.
`SingleThreadSchedulerStatisticTracker(TaskPriority defaultPriority, long maxWaitForLowPriorityInMs, boolean daemonThread)` Constructs a new `SingleThreadScheduler`.
`SingleThreadSchedulerStatisticTracker(TaskPriority defaultPriority, long maxWaitForLowPriorityInMs, boolean daemonThread, int maxStatisticWindowSize)` Constructs a new `SingleThreadScheduler`.
`SingleThreadSchedulerStatisticTracker(TaskPriority defaultPriority, long maxWaitForLowPriorityInMs, boolean daemonThread, int maxStatisticWindowSize, boolean accurateTime)` Constructs a new `SingleThreadScheduler`.
`SingleThreadSchedulerStatisticTracker(TaskPriority defaultPriority, long maxWaitForLowPriorityInMs, int maxStatisticWindowSize)` Constructs a new `SingleThreadScheduler`.
`SingleThreadSchedulerStatisticTracker(TaskPriority defaultPriority, long maxWaitForLowPriorityInMs, int maxStatisticWindowSize, boolean accurateTime)` Constructs a new `SingleThreadScheduler`.
`SingleThreadSchedulerStatisticTracker(TaskPriority defaultPriority, long maxWaitForLowPriorityInMs, java.util.concurrent.ThreadFactory threadFactory)` Constructs a new `SingleThreadScheduler`.
`SingleThreadSchedulerStatisticTracker(TaskPriority defaultPriority, long maxWaitForLowPriorityInMs, java.util.concurrent.ThreadFactory threadFactory, int maxStatisticWindowSize)` Constructs a new `SingleThreadScheduler`.
`SingleThreadSchedulerStatisticTracker(TaskPriority defaultPriority, long maxWaitForLowPriorityInMs, java.util.concurrent.ThreadFactory threadFactory, int maxStatisticWindowSize, boolean accurateTime)` Constructs a new `SingleThreadScheduler`.
`SingleThreadSchedulerStatisticTracker(java.util.concurrent.ThreadFactory threadFactory)` Constructs a new `SingleThreadScheduler`.
`SingleThreadSchedulerStatisticTracker(java.util.concurrent.ThreadFactory threadFactory, int maxStatisticWindowSize)` Constructs a new `SingleThreadScheduler`.
`SingleThreadSchedulerStatisticTracker(java.util.concurrent.ThreadFactory threadFactory, int maxStatisticWindowSize, boolean accurateTime)` Constructs a new `SingleThreadScheduler`.

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`double`	`getAverageExecutionDelay()` This reports the rolling average delay from when a task was expected to run, till when the executor actually started the task.
`double`	`getAverageExecutionDelay(TaskPriority priority)` Gets the average delay from when the task is ready, to when it is actually executed.
`double`	`getAverageExecutionDuration()` Get the average duration that tasks submitted through this executor have spent executing.
`double`	`getAverageExecutionDuration(TaskPriority priority)` Get the average duration that tasks submitted through this executor have spent executing.
`java.util.Map<java.lang.Double,java.lang.Long>`	`getExecutionDelayPercentiles(double... percentiles)` Gets percentile values for execution delays.
`java.util.Map<java.lang.Double,java.lang.Long>`	`getExecutionDelayPercentiles(TaskPriority priority, double... percentiles)` Gets percentile values for execution delays.
`java.util.List<java.lang.Long>`	`getExecutionDelaySamples()` Get raw sample data for task execution delays.
`java.util.List<java.lang.Long>`	`getExecutionDelaySamples(TaskPriority priority)` Call to get a list of all currently recorded times for execution delays.
`java.util.Map<java.lang.Double,java.lang.Long>`	`getExecutionDurationPercentiles(double... percentiles)` Gets percentile values for execution duration.
`java.util.Map<java.lang.Double,java.lang.Long>`	`getExecutionDurationPercentiles(TaskPriority priority, double... percentiles)` Gets percentile values for execution duration.
`java.util.List<java.lang.Long>`	`getExecutionDurationSamples()` Get raw sample data for task run durations.
`java.util.List<java.lang.Long>`	`getExecutionDurationSamples(TaskPriority priority)` Get raw sample data for task run durations.
`java.util.List<Pair<java.lang.Runnable,java.lang.StackTraceElement[]>>`	`getLongRunningTasks(long durationLimitMillis)` Call to get a list of runnables and stack traces from tasks which have been actively executing for a longer duration than the one provided.
`int`	`getLongRunningTasksQty(long durationLimitMillis)` Call to return the number of tasks which have been running longer than the provided duration in milliseconds.
`long`	`getTotalExecutionCount()` Call to get the total quantity of tasks this executor has handled.
`long`	`getTotalExecutionCount(TaskPriority priority)` Call to get the total quantity of tasks this executor has handled for a specific priority.
`void`	`resetCollectedStats()` Clears all collected rolling statistics.
`java.util.List<java.lang.Runnable>`	`shutdownNow()` Stops any new tasks from being submitted to the pool.

Methods inherited from class org.threadly.concurrent.SingleThreadScheduler
awaitTermination, awaitTermination, getActiveTaskCount, isShutdown, isTerminated, prestartExecutionThread, prestartExecutionThread, scheduleAtFixedRate, scheduleWithFixedDelay, shutdown

Methods inherited from class org.threadly.concurrent.AbstractPriorityScheduler
execute, getDefaultPriority, getMaxWaitForLowPriority, getQueuedTaskCount, getQueuedTaskCount, getWaitingForExecutionTaskCount, getWaitingForExecutionTaskCount, remove, remove, schedule, scheduleAtFixedRate, scheduleWithFixedDelay, setMaxWaitForLowPriority, submit, submit, submitScheduled, submitScheduled

Methods inherited from class org.threadly.concurrent.AbstractSubmitterScheduler
schedule, submitScheduled, submitScheduled

Methods inherited from class org.threadly.concurrent.AbstractSubmitterExecutor
execute, submit, submit

Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.threadly.concurrent.statistics.StatisticExecutor
getQueuedTaskCount

Methods inherited from interface org.threadly.concurrent.PrioritySchedulerService
execute, getDefaultPriority, getMaxWaitForLowPriority, getQueuedTaskCount, getWaitingForExecutionTaskCount, schedule, scheduleAtFixedRate, scheduleWithFixedDelay, submit, submit, submit, submitScheduled, submitScheduled, submitScheduled

Methods inherited from interface org.threadly.concurrent.SchedulerService
getActiveTaskCount, getQueuedTaskCount, getWaitingForExecutionTaskCount, isShutdown, remove, remove

Methods inherited from interface org.threadly.concurrent.SubmitterScheduler
schedule, scheduleAtFixedRate, scheduleWithFixedDelay, submitScheduled, submitScheduled, submitScheduled

Methods inherited from interface org.threadly.concurrent.SubmitterExecutor
submit, submit, submit

Methods inherited from interface java.util.concurrent.Executor
execute

- Constructor Detail
  - SingleThreadSchedulerStatisticTracker
```
public SingleThreadSchedulerStatisticTracker()
```
    Constructs a new SingleThreadScheduler. No threads will start until the first task is provided. This defaults to using a daemon thread for the scheduler.
    This defaults to inaccurate time. Meaning that durations and delays may under report (but NEVER OVER what they actually were). This has the least performance impact. If you want more accurate time consider using one of the constructors that accepts a boolean for accurate time.
  - SingleThreadSchedulerStatisticTracker
```
public SingleThreadSchedulerStatisticTracker(TaskPriority defaultPriority,
                                             long maxWaitForLowPriorityInMs)
```
    Constructs a new SingleThreadScheduler. No threads will start until the first task is provided. This defaults to using a daemon thread for the scheduler.
    This defaults to inaccurate time. Meaning that durations and delays may under report (but NEVER OVER what they actually were). This has the least performance impact. If you want more accurate time consider using one of the constructors that accepts a boolean for accurate time.
    
    Parameters:
    
    defaultPriority - Default priority for tasks which are submitted without any specified priority
    
    maxWaitForLowPriorityInMs - time low priority tasks to wait if there are high priority tasks ready to run
  - SingleThreadSchedulerStatisticTracker
```
public SingleThreadSchedulerStatisticTracker(boolean daemonThread)
```
    Constructs a new SingleThreadScheduler. No threads will start until the first task is provided.
    This defaults to inaccurate time. Meaning that durations and delays may under report (but NEVER OVER what they actually were). This has the least performance impact. If you want more accurate time consider using one of the constructors that accepts a boolean for accurate time.
    
    Parameters:
    
    daemonThread - true if scheduler thread should be a daemon thread
  - SingleThreadSchedulerStatisticTracker
```
public SingleThreadSchedulerStatisticTracker(TaskPriority defaultPriority,
                                             long maxWaitForLowPriorityInMs,
                                             boolean daemonThread)
```
    Constructs a new SingleThreadScheduler. No threads will start until the first task is provided.
    This defaults to inaccurate time. Meaning that durations and delays may under report (but NEVER OVER what they actually were). This has the least performance impact. If you want more accurate time consider using one of the constructors that accepts a boolean for accurate time.
    
    Parameters:
    
    defaultPriority - Default priority for tasks which are submitted without any specified priority
    
    maxWaitForLowPriorityInMs - time low priority tasks to wait if there are high priority tasks ready to run
    
    daemonThread - true if scheduler thread should be a daemon thread
  - SingleThreadSchedulerStatisticTracker
```
public SingleThreadSchedulerStatisticTracker(java.util.concurrent.ThreadFactory threadFactory)
```
    Constructs a new SingleThreadScheduler. No threads will start until the first task is provided.
    This defaults to inaccurate time. Meaning that durations and delays may under report (but NEVER OVER what they actually were). This has the least performance impact. If you want more accurate time consider using one of the constructors that accepts a boolean for accurate time.
    
    Parameters:
    
    threadFactory - factory to make thread for scheduler
  - SingleThreadSchedulerStatisticTracker
```
public SingleThreadSchedulerStatisticTracker(TaskPriority defaultPriority,
                                             long maxWaitForLowPriorityInMs,
                                             java.util.concurrent.ThreadFactory threadFactory)
```
    Constructs a new SingleThreadScheduler. No threads will start until the first task is provided.
    This defaults to inaccurate time. Meaning that durations and delays may under report (but NEVER OVER what they actually were). This has the least performance impact. If you want more accurate time consider using one of the constructors that accepts a boolean for accurate time.
    
    Parameters:
    
    defaultPriority - Default priority for tasks which are submitted without any specified priority
    
    maxWaitForLowPriorityInMs - time low priority tasks to wait if there are high priority tasks ready to run
    
    threadFactory - factory to make thread for scheduler
  - SingleThreadSchedulerStatisticTracker
```
public SingleThreadSchedulerStatisticTracker(int maxStatisticWindowSize)
```
    Constructs a new SingleThreadScheduler. No threads will start until the first task is provided. This defaults to using a daemon thread for the scheduler.
    This defaults to inaccurate time. Meaning that durations and delays may under report (but NEVER OVER what they actually were). This has the least performance impact. If you want more accurate time consider using one of the constructors that accepts a boolean for accurate time.
    
    Parameters:
    
    maxStatisticWindowSize - maximum number of samples to keep internally
  - SingleThreadSchedulerStatisticTracker
```
public SingleThreadSchedulerStatisticTracker(TaskPriority defaultPriority,
                                             long maxWaitForLowPriorityInMs,
                                             int maxStatisticWindowSize)
```
    Constructs a new SingleThreadScheduler. No threads will start until the first task is provided. This defaults to using a daemon thread for the scheduler.
    This defaults to inaccurate time. Meaning that durations and delays may under report (but NEVER OVER what they actually were). This has the least performance impact. If you want more accurate time consider using one of the constructors that accepts a boolean for accurate time.
    
    Parameters:
    
    defaultPriority - Default priority for tasks which are submitted without any specified priority
    
    maxWaitForLowPriorityInMs - time low priority tasks to wait if there are high priority tasks ready to run
    
    maxStatisticWindowSize - maximum number of samples to keep internally
  - SingleThreadSchedulerStatisticTracker
```
public SingleThreadSchedulerStatisticTracker(boolean daemonThread,
                                             int maxStatisticWindowSize)
```
    Constructs a new SingleThreadScheduler. No threads will start until the first task is provided.
    This defaults to inaccurate time. Meaning that durations and delays may under report (but NEVER OVER what they actually were). This has the least performance impact. If you want more accurate time consider using one of the constructors that accepts a boolean for accurate time.
    
    Parameters:
    
    daemonThread - true if scheduler thread should be a daemon thread
    
    maxStatisticWindowSize - maximum number of samples to keep internally
  - SingleThreadSchedulerStatisticTracker
```
public SingleThreadSchedulerStatisticTracker(TaskPriority defaultPriority,
                                             long maxWaitForLowPriorityInMs,
                                             boolean daemonThread,
                                             int maxStatisticWindowSize)
```
    Constructs a new SingleThreadScheduler. No threads will start until the first task is provided.
    This defaults to inaccurate time. Meaning that durations and delays may under report (but NEVER OVER what they actually were). This has the least performance impact. If you want more accurate time consider using one of the constructors that accepts a boolean for accurate time.
    
    Parameters:
    
    defaultPriority - Default priority for tasks which are submitted without any specified priority
    
    maxWaitForLowPriorityInMs - time low priority tasks to wait if there are high priority tasks ready to run
    
    daemonThread - true if scheduler thread should be a daemon thread
    
    maxStatisticWindowSize - maximum number of samples to keep internally
  - SingleThreadSchedulerStatisticTracker
```
public SingleThreadSchedulerStatisticTracker(java.util.concurrent.ThreadFactory threadFactory,
                                             int maxStatisticWindowSize)
```
    Constructs a new SingleThreadScheduler. No threads will start until the first task is provided.
    This defaults to inaccurate time. Meaning that durations and delays may under report (but NEVER OVER what they actually were). This has the least performance impact. If you want more accurate time consider using one of the constructors that accepts a boolean for accurate time.
    
    Parameters:
    
    threadFactory - factory to make thread for scheduler
    
    maxStatisticWindowSize - maximum number of samples to keep internally
  - SingleThreadSchedulerStatisticTracker
```
public SingleThreadSchedulerStatisticTracker(TaskPriority defaultPriority,
                                             long maxWaitForLowPriorityInMs,
                                             java.util.concurrent.ThreadFactory threadFactory,
                                             int maxStatisticWindowSize)
```
    Constructs a new SingleThreadScheduler. No threads will start until the first task is provided.
    This defaults to inaccurate time. Meaning that durations and delays may under report (but NEVER OVER what they actually were). This has the least performance impact. If you want more accurate time consider using one of the constructors that accepts a boolean for accurate time.
    
    Parameters:
    
    defaultPriority - Default priority for tasks which are submitted without any specified priority
    
    maxWaitForLowPriorityInMs - time low priority tasks to wait if there are high priority tasks ready to run
    
    threadFactory - factory to make thread for scheduler
    
    maxStatisticWindowSize - maximum number of samples to keep internally
  - SingleThreadSchedulerStatisticTracker
```
public SingleThreadSchedulerStatisticTracker(int maxStatisticWindowSize,
                                             boolean accurateTime)
```
    Constructs a new SingleThreadScheduler. No threads will start until the first task is provided. This defaults to using a daemon thread for the scheduler.
    
    Parameters:
    
    maxStatisticWindowSize - maximum number of samples to keep internally
    
    accurateTime - true to ensure that delays and durations are not under reported
  - SingleThreadSchedulerStatisticTracker
```
public SingleThreadSchedulerStatisticTracker(TaskPriority defaultPriority,
                                             long maxWaitForLowPriorityInMs,
                                             int maxStatisticWindowSize,
                                             boolean accurateTime)
```
    Constructs a new SingleThreadScheduler. No threads will start until the first task is provided. This defaults to using a daemon thread for the scheduler.
    
    Parameters:
    
    defaultPriority - Default priority for tasks which are submitted without any specified priority
    
    maxWaitForLowPriorityInMs - time low priority tasks to wait if there are high priority tasks ready to run
    
    maxStatisticWindowSize - maximum number of samples to keep internally
    
    accurateTime - true to ensure that delays and durations are not under reported
  - SingleThreadSchedulerStatisticTracker
```
public SingleThreadSchedulerStatisticTracker(boolean daemonThread,
                                             int maxStatisticWindowSize,
                                             boolean accurateTime)
```
    Constructs a new SingleThreadScheduler. No threads will start until the first task is provided.
    
    Parameters:
    
    daemonThread - true if scheduler thread should be a daemon thread
    
    maxStatisticWindowSize - maximum number of samples to keep internally
    
    accurateTime - true to ensure that delays and durations are not under reported
  - SingleThreadSchedulerStatisticTracker
```
public SingleThreadSchedulerStatisticTracker(TaskPriority defaultPriority,
                                             long maxWaitForLowPriorityInMs,
                                             boolean daemonThread,
                                             int maxStatisticWindowSize,
                                             boolean accurateTime)
```
    Constructs a new SingleThreadScheduler. No threads will start until the first task is provided.
    
    Parameters:
    
    defaultPriority - Default priority for tasks which are submitted without any specified priority
    
    maxWaitForLowPriorityInMs - time low priority tasks to wait if there are high priority tasks ready to run
    
    daemonThread - true if scheduler thread should be a daemon thread
    
    maxStatisticWindowSize - maximum number of samples to keep internally
    
    accurateTime - true to ensure that delays and durations are not under reported
  - SingleThreadSchedulerStatisticTracker
```
public SingleThreadSchedulerStatisticTracker(java.util.concurrent.ThreadFactory threadFactory,
                                             int maxStatisticWindowSize,
                                             boolean accurateTime)
```
    Constructs a new SingleThreadScheduler. No threads will start until the first task is provided.
    
    Parameters:
    
    threadFactory - factory to make thread for scheduler
    
    maxStatisticWindowSize - maximum number of samples to keep internally
    
    accurateTime - true to ensure that delays and durations are not under reported
  - SingleThreadSchedulerStatisticTracker
```
public SingleThreadSchedulerStatisticTracker(TaskPriority defaultPriority,
                                             long maxWaitForLowPriorityInMs,
                                             java.util.concurrent.ThreadFactory threadFactory,
                                             int maxStatisticWindowSize,
                                             boolean accurateTime)
```
    Constructs a new SingleThreadScheduler. No threads will start until the first task is provided.
    
    Parameters:
    
    defaultPriority - Default priority for tasks which are submitted without any specified priority
    
    maxWaitForLowPriorityInMs - time low priority tasks to wait if there are high priority tasks ready to run
    
    threadFactory - factory to make thread for scheduler
    
    maxStatisticWindowSize - maximum number of samples to keep internally
    
    accurateTime - true to ensure that delays and durations are not under reported
- Method Detail
  - shutdownNow
```
public java.util.List<java.lang.Runnable> shutdownNow()
```
    Description copied from class: SingleThreadScheduler
    
    Stops any new tasks from being submitted to the pool. If any tasks are waiting for execution they will be prevented from being run. If a task is currently running it will be allowed to finish (though this call will not block waiting for it to finish).
    
    Overrides:
    
    shutdownNow in class SingleThreadScheduler
    
    Returns:
    
    returns a list of runnables which were waiting in the queue to be run at time of shutdown
  - getExecutionDelaySamples
```
public java.util.List<java.lang.Long> getExecutionDelaySamples()
```
    Description copied from interface: StatisticPriorityScheduler
    
    Get raw sample data for task execution delays. This raw data can be used for more advanced statistics which are not provided in this library. These can also be fed into utilities in StatisticsUtils for additional statistics.
    The returned result set includes all priorities. If you want durations for a specific priority use StatisticPriorityScheduler.getExecutionDelaySamples(TaskPriority).
    
    Specified by:
    
    getExecutionDelaySamples in interface StatisticExecutor
    
    Specified by:
    
    getExecutionDelaySamples in interface StatisticPriorityScheduler
    
    Returns:
    
    A list of delay times in milliseconds before a task was executed
  - getExecutionDelaySamples
```
public java.util.List<java.lang.Long> getExecutionDelaySamples(TaskPriority priority)
```
    Description copied from interface: StatisticPriorityScheduler
    
    Call to get a list of all currently recorded times for execution delays. This is the window used for the rolling average for StatisticPriorityScheduler.getAverageExecutionDelay(TaskPriority). This call allows for more complex statistics (ie looking for outliers, etc).
    
    Specified by:
    
    getExecutionDelaySamples in interface StatisticPriorityScheduler
    
    Parameters:
    
    priority - Task priority to provide samples for
    
    Returns:
    
    list which represents execution delay samples
  - getAverageExecutionDelay
```
public double getAverageExecutionDelay()
```
    Description copied from interface: StatisticPriorityScheduler
    
    This reports the rolling average delay from when a task was expected to run, till when the executor actually started the task. This will return -1 if no samples have been collected yet. This call averages over all priority types, if you want the delay for a specific priority use StatisticPriorityScheduler.getAverageExecutionDelay(TaskPriority).
    
    Specified by:
    
    getAverageExecutionDelay in interface StatisticExecutor
    
    Specified by:
    
    getAverageExecutionDelay in interface StatisticPriorityScheduler
    
    Returns:
    
    Average delay for tasks to be executed in milliseconds
  - getAverageExecutionDelay
```
public double getAverageExecutionDelay(TaskPriority priority)
```
    Description copied from interface: StatisticPriorityScheduler
    
    Gets the average delay from when the task is ready, to when it is actually executed. This will only inspect the times for a specific priority.
    
    Specified by:
    
    getAverageExecutionDelay in interface StatisticPriorityScheduler
    
    Parameters:
    
    priority - Specific task priority which statistics should be calculated against
    
    Returns:
    
    Average delay for tasks to be executed in milliseconds
  - getExecutionDelayPercentiles
```
public java.util.Map<java.lang.Double,java.lang.Long> getExecutionDelayPercentiles(double... percentiles)
```
    Description copied from interface: StatisticPriorityScheduler
    
    Gets percentile values for execution delays. This function accepts any decimal percentile between zero and one hundred.
    The returned map's keys correspond exactly to the percentiles provided. Iterating over the returned map will iterate in order of the requested percentiles as well.
    These percentiles are across all priorities combined into the same data set. If you want percentiles for a specific priority use StatisticPriorityScheduler.getExecutionDelayPercentiles(TaskPriority, double...).
    
    Specified by:
    
    getExecutionDelayPercentiles in interface StatisticExecutor
    
    Specified by:
    
    getExecutionDelayPercentiles in interface StatisticPriorityScheduler
    
    Parameters:
    
    percentiles - Percentiles requested, any decimal values between 0 and 100 (inclusive)
    
    Returns:
    
    Map with keys being the percentiles requested, value being the execution delay in milliseconds
  - getExecutionDelayPercentiles
```
public java.util.Map<java.lang.Double,java.lang.Long> getExecutionDelayPercentiles(TaskPriority priority,
                                                                                   double... percentiles)
```
    Description copied from interface: StatisticPriorityScheduler
    
    Gets percentile values for execution delays. This function accepts any decimal percentile between zero and one hundred.
    The returned map's keys correspond exactly to the percentiles provided. Iterating over the returned map will iterate in order of the requested percentiles as well.
    
    Specified by:
    
    getExecutionDelayPercentiles in interface StatisticPriorityScheduler
    
    Parameters:
    
    priority - Specific task priority which statistics should be calculated against
    
    percentiles - Percentiles requested, any decimal values between 0 and 100 (inclusive)
    
    Returns:
    
    Map with keys being the percentiles requested, value being the execution delay in milliseconds
  - getExecutionDurationSamples
```
public java.util.List<java.lang.Long> getExecutionDurationSamples()
```
    Description copied from interface: StatisticPriorityScheduler
    
    Get raw sample data for task run durations. This raw data can be used for more advanced statistics which are not provided in this library. These can also be fed into utilities in StatisticsUtils for additional statistics.
    The returned result set includes all priorities. If you want durations for a specific priority use StatisticPriorityScheduler.getExecutionDurationSamples(TaskPriority).
    
    Specified by:
    
    getExecutionDurationSamples in interface StatisticExecutor
    
    Specified by:
    
    getExecutionDurationSamples in interface StatisticPriorityScheduler
    
    Returns:
    
    A list of task durations in milliseconds
  - getExecutionDurationSamples
```
public java.util.List<java.lang.Long> getExecutionDurationSamples(TaskPriority priority)
```
    Description copied from interface: StatisticPriorityScheduler
    
    Get raw sample data for task run durations. This raw data can be used for more advanced statistics which are not provided in this library. These can also be fed into utilities in StatisticsUtils for additional statistics.
    These result set includes all priorities. If you want durations for a specific priority use StatisticPriorityScheduler.getExecutionDurationSamples(TaskPriority).
    
    Specified by:
    
    getExecutionDurationSamples in interface StatisticPriorityScheduler
    
    Parameters:
    
    priority - Task priority to provide samples for
    
    Returns:
    
    A list of task durations in milliseconds
  - getAverageExecutionDuration
```
public double getAverageExecutionDuration()
```
    Description copied from interface: StatisticPriorityScheduler
    
    Get the average duration that tasks submitted through this executor have spent executing. This only reports samples from tasks which have completed (in-progress tasks are not considered).
    This call averages over all priority types, if you want the duration for a specific priority use StatisticPriorityScheduler.getAverageExecutionDuration(TaskPriority).
    
    Specified by:
    
    getAverageExecutionDuration in interface StatisticExecutor
    
    Specified by:
    
    getAverageExecutionDuration in interface StatisticPriorityScheduler
    
    Returns:
    
    Average task execution duration in milliseconds
  - getAverageExecutionDuration
```
public double getAverageExecutionDuration(TaskPriority priority)
```
    Description copied from interface: StatisticPriorityScheduler
    
    Get the average duration that tasks submitted through this executor have spent executing. This only reports samples from tasks which have completed (in-progress tasks are not considered).
    
    Specified by:
    
    getAverageExecutionDuration in interface StatisticPriorityScheduler
    
    Parameters:
    
    priority - Specific task priority which statistics should be calculated against
    
    Returns:
    
    Average task execution duration in milliseconds
  - getExecutionDurationPercentiles
```
public java.util.Map<java.lang.Double,java.lang.Long> getExecutionDurationPercentiles(double... percentiles)
```
    Description copied from interface: StatisticPriorityScheduler
    
    Gets percentile values for execution duration. This function accepts any decimal percentile between zero and one hundred.
    The returned map's keys correspond exactly to the percentiles provided. Iterating over the returned map will iterate in order of the requested percentiles as well.
    These percentiles are across all priorities combined into the same data set. If you want percentiles for a specific priority use StatisticPriorityScheduler.getExecutionDurationPercentiles(TaskPriority, double...).
    
    Specified by:
    
    getExecutionDurationPercentiles in interface StatisticExecutor
    
    Specified by:
    
    getExecutionDurationPercentiles in interface StatisticPriorityScheduler
    
    Parameters:
    
    percentiles - Percentiles requested, any decimal values between 0 and 100 (inclusive)
    
    Returns:
    
    Map with keys being the percentiles requested, value being the execution duration in milliseconds
  - getExecutionDurationPercentiles
```
public java.util.Map<java.lang.Double,java.lang.Long> getExecutionDurationPercentiles(TaskPriority priority,
                                                                                      double... percentiles)
```
    Description copied from interface: StatisticPriorityScheduler
    
    Gets percentile values for execution duration. This function accepts any decimal percentile between zero and one hundred.
    The returned map's keys correspond exactly to the percentiles provided. Iterating over the returned map will iterate in order of the requested percentiles as well.
    
    Specified by:
    
    getExecutionDurationPercentiles in interface StatisticPriorityScheduler
    
    Parameters:
    
    priority - Specific task priority which statistics should be calculated against
    
    percentiles - Percentiles requested, any decimal values between 0 and 100 (inclusive)
    
    Returns:
    
    Map with keys being the percentiles requested, value being the execution duration in milliseconds
  - getLongRunningTasks
```
public java.util.List<Pair<java.lang.Runnable,java.lang.StackTraceElement[]>> getLongRunningTasks(long durationLimitMillis)
```
    Description copied from interface: StatisticExecutor
    
    Call to get a list of runnables and stack traces from tasks which have been actively executing for a longer duration than the one provided. Time in queue waiting for execution is not considered as part of the execution duration.
    If only the quantity of long running tasks is needed, please use StatisticExecutor.getLongRunningTasksQty(long). Since it does not need to generate stack traces it is a cheaper alternative.
    The left side of the Pair is the runnable task submitted. If the task was submitted as a Callable the Runnable will be of type: ListenableFutureTask. Casting and invoking ListenableFutureTask.getContainedCallable() will allow you to get to your original Callable.
    The right side of the Pair is a single sample of what that long running tasks stack was. Because these tasks are running concurrently by the time this function returns the provided tasks may have completed.
    
    Specified by:
    
    getLongRunningTasks in interface StatisticExecutor
    
    Parameters:
    
    durationLimitMillis - Limit for tasks execution, if task execution time is below this they will be ignored
    
    Returns:
    
    List of long running runnables with their corresponding stack traces
  - getLongRunningTasksQty
```
public int getLongRunningTasksQty(long durationLimitMillis)
```
    Description copied from interface: StatisticExecutor
    
    Call to return the number of tasks which have been running longer than the provided duration in milliseconds. While iterating over running tasks, it may be possible that some previously examine tasks have completed before this ran. There is no attempt to lock tasks from starting or stopping during this check.
    
    Specified by:
    
    getLongRunningTasksQty in interface StatisticExecutor
    
    Parameters:
    
    durationLimitMillis - threshold of time in milliseconds a task must have been executing
    
    Returns:
    
    total quantity of tasks which have or are running longer than the provided time length
  - resetCollectedStats
```
public void resetCollectedStats()
```
    Description copied from interface: StatisticExecutor
    
    Clears all collected rolling statistics. These are the statistics used for averages and are limited by window sizes.
    This does NOT reset the total execution counts.
    
    Specified by:
    
    resetCollectedStats in interface StatisticExecutor
  - getTotalExecutionCount
```
public long getTotalExecutionCount()
```
    Description copied from interface: StatisticExecutor
    
    Call to get the total quantity of tasks this executor has handled.
    
    Specified by:
    
    getTotalExecutionCount in interface StatisticExecutor
    
    Returns:
    
    total quantity of tasks run
  - getTotalExecutionCount
```
public long getTotalExecutionCount(TaskPriority priority)
```
    Description copied from interface: StatisticPriorityScheduler
    
    Call to get the total quantity of tasks this executor has handled for a specific priority.
    
    Specified by:
    
    getTotalExecutionCount in interface StatisticPriorityScheduler
    
    Parameters:
    
    priority - Specific task priority which statistics should be calculated against
    
    Returns:
    
    total quantity of tasks run

Class SingleThreadSchedulerStatisticTracker

Constructor Summary

Method Summary

Methods inherited from class org.threadly.concurrent.SingleThreadScheduler

Methods inherited from class org.threadly.concurrent.AbstractPriorityScheduler

Methods inherited from class org.threadly.concurrent.AbstractSubmitterScheduler

Methods inherited from class org.threadly.concurrent.AbstractSubmitterExecutor

Methods inherited from class java.lang.Object

Methods inherited from interface org.threadly.concurrent.statistics.StatisticExecutor

Methods inherited from interface org.threadly.concurrent.PrioritySchedulerService

Methods inherited from interface org.threadly.concurrent.SchedulerService

Methods inherited from interface org.threadly.concurrent.SubmitterScheduler

Methods inherited from interface org.threadly.concurrent.SubmitterExecutor

Methods inherited from interface java.util.concurrent.Executor

Constructor Detail

SingleThreadSchedulerStatisticTracker

SingleThreadSchedulerStatisticTracker

SingleThreadSchedulerStatisticTracker

SingleThreadSchedulerStatisticTracker

SingleThreadSchedulerStatisticTracker

SingleThreadSchedulerStatisticTracker

SingleThreadSchedulerStatisticTracker

SingleThreadSchedulerStatisticTracker

SingleThreadSchedulerStatisticTracker

SingleThreadSchedulerStatisticTracker

SingleThreadSchedulerStatisticTracker

SingleThreadSchedulerStatisticTracker

SingleThreadSchedulerStatisticTracker

SingleThreadSchedulerStatisticTracker

SingleThreadSchedulerStatisticTracker

SingleThreadSchedulerStatisticTracker

SingleThreadSchedulerStatisticTracker

SingleThreadSchedulerStatisticTracker

Method Detail

shutdownNow

getExecutionDelaySamples

getExecutionDelaySamples

getAverageExecutionDelay

getAverageExecutionDelay

getExecutionDelayPercentiles

getExecutionDelayPercentiles

getExecutionDurationSamples

getExecutionDurationSamples

getAverageExecutionDuration

getAverageExecutionDuration

getExecutionDurationPercentiles

getExecutionDurationPercentiles

getLongRunningTasks

getLongRunningTasksQty

resetCollectedStats

getTotalExecutionCount

getTotalExecutionCount