Package ca.spottedleaf.concurrentutil.executor.thread

Class BalancedPrioritisedThreadPool

java.lang.Object

ca.spottedleaf.concurrentutil.executor.thread.BalancedPrioritisedThreadPool

public final class BalancedPrioritisedThreadPool
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
final class	BalancedPrioritisedThreadPool.OrderedStreamGroup

Field Summary

Fields

Modifier and Type	Field	Description
static final long	DEFAULT_FLAGS
static final long	DEFAULT_GROUP_TIME_SLICE
static final long	FLAG_ORDER_BY_STREAM	Whether to order tasks by (lower) stream id after (higher) priority

Constructor Summary

Constructors

Constructor	Description
BalancedPrioritisedThreadPool(long groupTimeSliceNS, ThreadFactory threadFactory)
BalancedPrioritisedThreadPool(long groupTimeSliceNS, ThreadFactory threadFactory, long flags)

Method Summary

Modifier and Type	Method	Description
void	adjustThreadCount(int threads)
BalancedPrioritisedThreadPool.OrderedStreamGroup	createOrderedStreamGroup()
BalancedPrioritisedThreadPool.OrderedStreamGroup	createOrderedStreamGroup(AtomicLong subOrderGenerate)
Thread[]	getAliveThreads()
Thread[]	getCoreThreads()
void	halt(boolean shutdownQueues)	Prevents creation of new queues, shutdowns all non-shutdown queues if specified
boolean	join(long msToWait)	Waits until all threads in this pool have shutdown, or until the specified time has passed.
boolean	joinInterruptable(long msToWait)	Waits until all threads in this pool have shutdown, or until the specified time has passed.
void	shutdown(boolean wait)	Shuts down this thread pool, optionally waiting for all tasks to be executed.

Methods inherited from class java.lang.Object

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

Field Details

DEFAULT_GROUP_TIME_SLICE

public static final long DEFAULT_GROUP_TIME_SLICE

See Also:

• Constant Field Values

FLAG_ORDER_BY_STREAM

public static final long FLAG_ORDER_BY_STREAM

Whether to order tasks by (lower) stream id after (higher) priority

See Also:

• Constant Field Values

DEFAULT_FLAGS

public static final long DEFAULT_FLAGS

See Also:

• Constant Field Values

Constructor Details

BalancedPrioritisedThreadPool

public BalancedPrioritisedThreadPool(long groupTimeSliceNS,
 ThreadFactory threadFactory)

BalancedPrioritisedThreadPool

public BalancedPrioritisedThreadPool(long groupTimeSliceNS,
 ThreadFactory threadFactory,
 long flags)

Method Details

getAliveThreads

public Thread[] getAliveThreads()

getCoreThreads

public Thread[] getCoreThreads()

halt

public void halt(boolean shutdownQueues)

Prevents creation of new queues, shutdowns all non-shutdown queues if specified

join

public boolean join(long msToWait)

Waits until all threads in this pool have shutdown, or until the specified time has passed.

Parameters:

msToWait - Maximum time to wait.

Returns:

false if the maximum time passed, true otherwise.

joinInterruptable

public boolean joinInterruptable(long msToWait)
                          throws InterruptedException

Waits until all threads in this pool have shutdown, or until the specified time has passed.

Parameters:

msToWait - Maximum time to wait.

Returns:

false if the maximum time passed, true otherwise.

Throws:

InterruptedException - If this thread is interrupted.

shutdown

public void shutdown(boolean wait)

Shuts down this thread pool, optionally waiting for all tasks to be executed. This function will invoke PrioritisedExecutor.shutdown() on all created executors on this thread pool.

Parameters:

wait - Whether to wait for tasks to be executed

adjustThreadCount

public void adjustThreadCount(int threads)

createOrderedStreamGroup

public BalancedPrioritisedThreadPool.OrderedStreamGroup createOrderedStreamGroup()

createOrderedStreamGroup

public BalancedPrioritisedThreadPool.OrderedStreamGroup createOrderedStreamGroup(AtomicLong subOrderGenerate)