com.github.rholder.moar.concurrent

Class StrategicExecutors

java.lang.Object

com.github.rholder.moar.concurrent.StrategicExecutors

public class StrategicExecutors
extends java.lang.Object

Provide some convenience functions for creating new BalancingThreadPoolExecutor instances.

Field Summary

Fields

Modifier and Type	Field and Description
static int	DEFAULT_BALANCE_AFTER
static float	DEFAULT_SMOOTHING_WEIGHT

Constructor Summary

Constructors

Constructor and Description
StrategicExecutors()

Method Summary

Methods

Modifier and Type	Method and Description
static BalancingThreadPoolExecutor	newBalancingThreadPoolExecutor(int maxThreads, float targetUtilization) Return a capped BalancingThreadPoolExecutor with the given maximum number of threads and target utilization.
static BalancingThreadPoolExecutor	newBalancingThreadPoolExecutor(int maxThreads, float targetUtilization, float smoothingWeight, int balanceAfter) Return a capped BalancingThreadPoolExecutor with the given maximum number of threads, target utilization, smoothing weight, and balance after values.
static BalancingThreadPoolExecutor	newBalancingThreadPoolExecutor(java.util.concurrent.ThreadPoolExecutor tpe, float targetUtilization, float smoothingWeight, int balanceAfter) Return a BalancingThreadPoolExecutor with the given ThreadPoolExecutor, target utilization, smoothing weight, and balance after values.

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_SMOOTHING_WEIGHT

public static final float DEFAULT_SMOOTHING_WEIGHT

See Also:

Constant Field Values

DEFAULT_BALANCE_AFTER

public static final int DEFAULT_BALANCE_AFTER

See Also:

Constant Field Values

Constructor Detail

StrategicExecutors

public StrategicExecutors()

Method Detail

newBalancingThreadPoolExecutor

public static BalancingThreadPoolExecutor newBalancingThreadPoolExecutor(int maxThreads,
                                                         float targetUtilization)

Return a capped BalancingThreadPoolExecutor with the given maximum number of threads and target utilization. The default smoothing weight and balance after constants are used.

Parameters:

maxThreads - maximum number of threads to use

targetUtilization - a float between 0.0 and 1.0 representing the percentage of the total CPU time to be used by this pool

newBalancingThreadPoolExecutor

public static BalancingThreadPoolExecutor newBalancingThreadPoolExecutor(int maxThreads,
                                                         float targetUtilization,
                                                         float smoothingWeight,
                                                         int balanceAfter)

Return a capped BalancingThreadPoolExecutor with the given maximum number of threads, target utilization, smoothing weight, and balance after values.

Parameters:

maxThreads - maximum number of threads to use

targetUtilization - a float between 0.0 and 1.0 representing the percentage of the total CPU time to be used by this pool

smoothingWeight - smooth out the averages of the CPU and wait time over time such that tasks aren't too heavily skewed with old or spiking data

balanceAfter - balance the thread pool after this many tasks have run

newBalancingThreadPoolExecutor

public static BalancingThreadPoolExecutor newBalancingThreadPoolExecutor(java.util.concurrent.ThreadPoolExecutor tpe,
                                                         float targetUtilization,
                                                         float smoothingWeight,
                                                         int balanceAfter)

Return a BalancingThreadPoolExecutor with the given ThreadPoolExecutor, target utilization, smoothing weight, and balance after values.

Parameters:

tpe - the underlying executor to use for this instance

targetUtilization - a float between 0.0 and 1.0 representing the percentage of the total CPU time to be used by this pool

smoothingWeight - smooth out the averages of the CPU and wait time over time such that tasks aren't too heavily skewed with old or spiking data

balanceAfter - balance the thread pool after this many tasks have run