A B C D E G H I M N O P Q R S T W

A

add(E) - Method in class com.github.rholder.moar.concurrent.StrategicBlockingQueue

add(E) - Method in class com.github.rholder.moar.concurrent.WrappedBlockingQueue

addAll(Collection<? extends E>) - Method in class com.github.rholder.moar.concurrent.WrappedBlockingQueue

avgCpuTime - Variable in class com.github.rholder.moar.concurrent.thread.Tracking

avgTotalTime - Variable in class com.github.rholder.moar.concurrent.thread.Tracking

awaitTermination(long, TimeUnit) - Method in class com.github.rholder.moar.concurrent.thread.BalancingThreadPoolExecutor

B

BalancingThreadPoolExecutor - Class in com.github.rholder.moar.concurrent.thread

This is a rough implementation of an auto-balancing thread pool to optimize for the following condition: optimal pool size = N * U * (1 + (W/C)) where N is the number of CPU's, U is the desired utilization, W is the time each thread spends waiting, and C is the time each thread spends using the CPU.

BalancingThreadPoolExecutor(ThreadPoolExecutor, ThreadProfiler, float, float, int) - Constructor for class com.github.rholder.moar.concurrent.thread.BalancingThreadPoolExecutor

C

CallerBlocksPolicy - Class in com.github.rholder.moar.concurrent.thread

This RejectedExecutionHandler blocks the current thread until the backing queue for a ThreadPoolExecutor can accept another task.

CallerBlocksPolicy() - Constructor for class com.github.rholder.moar.concurrent.thread.CallerBlocksPolicy

clear() - Method in class com.github.rholder.moar.concurrent.WrappedBlockingQueue

com.github.rholder.moar.concurrent - package com.github.rholder.moar.concurrent

com.github.rholder.moar.concurrent.thread - package com.github.rholder.moar.concurrent.thread

contains(Object) - Method in class com.github.rholder.moar.concurrent.WrappedBlockingQueue

containsAll(Collection<?>) - Method in class com.github.rholder.moar.concurrent.WrappedBlockingQueue

D

DEFAULT_BALANCE_AFTER - Static variable in class com.github.rholder.moar.concurrent.StrategicExecutors

DEFAULT_SMOOTHING_WEIGHT - Static variable in class com.github.rholder.moar.concurrent.StrategicExecutors

drainTo(Collection<? super E>) - Method in class com.github.rholder.moar.concurrent.WrappedBlockingQueue

drainTo(Collection<? super E>, int) - Method in class com.github.rholder.moar.concurrent.WrappedBlockingQueue

E

element() - Method in class com.github.rholder.moar.concurrent.WrappedBlockingQueue

execute(Runnable) - Method in class com.github.rholder.moar.concurrent.thread.BalancingThreadPoolExecutor

G

getThreadCpuTime(long) - Method in class com.github.rholder.moar.concurrent.thread.MXBeanThreadProfiler

getThreadCpuTime(long) - Method in interface com.github.rholder.moar.concurrent.thread.ThreadProfiler

Return the number of nanoseconds of CPU time used by the thread with the given id.

getThreadWaitTime(long) - Method in class com.github.rholder.moar.concurrent.thread.MXBeanThreadProfiler

getThreadWaitTime(long) - Method in interface com.github.rholder.moar.concurrent.thread.ThreadProfiler

Return the number of nanoseconds of waiting time used by the thread with the given id.

H

HeapQueueingStrategy<E> - Class in com.github.rholder.moar.concurrent

This QueueingStrategy slows down the rate at which items can be added to a queue based on the amount of free heap space available.

HeapQueueingStrategy(double, long, long) - Constructor for class com.github.rholder.moar.concurrent.HeapQueueingStrategy

Construct a new HeapQueueingStrategy with the given parameters.

I

isEmpty() - Method in class com.github.rholder.moar.concurrent.WrappedBlockingQueue

isShutdown() - Method in class com.github.rholder.moar.concurrent.thread.BalancingThreadPoolExecutor

isTerminated() - Method in class com.github.rholder.moar.concurrent.thread.BalancingThreadPoolExecutor

iterator() - Method in class com.github.rholder.moar.concurrent.WrappedBlockingQueue

M

MXBeanThreadProfiler - Class in com.github.rholder.moar.concurrent.thread

Use the ThreadMXBean implementation to provide thread information.

MXBeanThreadProfiler() - Constructor for class com.github.rholder.moar.concurrent.thread.MXBeanThreadProfiler

ThreadContentionMonitoring and ThreadCpuTime are both turned on when constructing this class.

N

newBalancingThreadPoolExecutor(int, float) - Static method in class com.github.rholder.moar.concurrent.StrategicExecutors

Return a capped BalancingThreadPoolExecutor with the given maximum number of threads and target utilization.

newBalancingThreadPoolExecutor(int, float, float, int) - Static method in class com.github.rholder.moar.concurrent.StrategicExecutors

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

newBalancingThreadPoolExecutor(ThreadPoolExecutor, float, float, int) - Static method in class com.github.rholder.moar.concurrent.StrategicExecutors

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

newHeapQueueingStrategy(double, long, long) - Static method in class com.github.rholder.moar.concurrent.QueueingStrategies

Construct a new HeapQueueingStrategy with the given parameters.

newStrategicArrayBlockingQueue(int, QueueingStrategy<V>) - Static method in class com.github.rholder.moar.concurrent.StrategicQueues

Return a StrategicBlockingQueue backed by an ArrayBlockingQueue of the given capacity using the given QueueingStrategy.

newStrategicBlockingQueue(BlockingQueue<V>, QueueingStrategy<V>) - Static method in class com.github.rholder.moar.concurrent.StrategicQueues

Return a StrategicBlockingQueue backed by the given BlockingQueue using the given QueueingStrategy.

newStrategicLinkedBlockingQueue(QueueingStrategy<V>) - Static method in class com.github.rholder.moar.concurrent.StrategicQueues

Return a StrategicBlockingQueue backed by a LinkedBlockingQueue using the given QueueingStrategy.

O

offer(E) - Method in class com.github.rholder.moar.concurrent.WrappedBlockingQueue

offer(E, long, TimeUnit) - Method in class com.github.rholder.moar.concurrent.WrappedBlockingQueue

onAfterAdd() - Method in class com.github.rholder.moar.concurrent.HeapQueueingStrategy

onAfterAdd() - Method in interface com.github.rholder.moar.concurrent.QueueingStrategy

Perform this action after adding a value to the queue.

onAfterRemove(E) - Method in class com.github.rholder.moar.concurrent.HeapQueueingStrategy

Increment the count of removed items from the queue.

onAfterRemove(E) - Method in interface com.github.rholder.moar.concurrent.QueueingStrategy

Perform this action before removing the given value from the queue.

onBeforeAdd(E) - Method in class com.github.rholder.moar.concurrent.HeapQueueingStrategy

Block for a varying amount based on how close the system is to the max heap space.

onBeforeAdd(E) - Method in interface com.github.rholder.moar.concurrent.QueueingStrategy

Perform this action before adding the given value to the queue.

onBeforeRemove() - Method in class com.github.rholder.moar.concurrent.HeapQueueingStrategy

onBeforeRemove() - Method in interface com.github.rholder.moar.concurrent.QueueingStrategy

Perform this action before removing a value from the queue.

P

peek() - Method in class com.github.rholder.moar.concurrent.WrappedBlockingQueue

poll(long, TimeUnit) - Method in class com.github.rholder.moar.concurrent.StrategicBlockingQueue

poll() - Method in class com.github.rholder.moar.concurrent.StrategicBlockingQueue

poll() - Method in class com.github.rholder.moar.concurrent.WrappedBlockingQueue

poll(long, TimeUnit) - Method in class com.github.rholder.moar.concurrent.WrappedBlockingQueue

put(E) - Method in class com.github.rholder.moar.concurrent.StrategicBlockingQueue

put(E) - Method in class com.github.rholder.moar.concurrent.WrappedBlockingQueue

Q

QueueingStrategies - Class in com.github.rholder.moar.concurrent

This is a helper class for instantiating available QueueingStrategy's.

QueueingStrategies() - Constructor for class com.github.rholder.moar.concurrent.QueueingStrategies

QueueingStrategy<E> - Interface in com.github.rholder.moar.concurrent

Implementations of this class perform actions before and after adding or removing items from a queue (i.e.

R

rejectedExecution(Runnable, ThreadPoolExecutor) - Method in class com.github.rholder.moar.concurrent.thread.CallerBlocksPolicy

Instead of throwing away the rejected task, put it back onto the queue that the ThreadPoolExecutor is using, effectively blocking execution until the put() succeeds or results in an InterruptedException which is wrapped and rethrown as a RejectedExecutionException.

remainingCapacity() - Method in class com.github.rholder.moar.concurrent.WrappedBlockingQueue

remove() - Method in class com.github.rholder.moar.concurrent.WrappedBlockingQueue

remove(Object) - Method in class com.github.rholder.moar.concurrent.WrappedBlockingQueue

removeAll(Collection<?>) - Method in class com.github.rholder.moar.concurrent.WrappedBlockingQueue

retainAll(Collection<?>) - Method in class com.github.rholder.moar.concurrent.WrappedBlockingQueue

S

shutdown() - Method in class com.github.rholder.moar.concurrent.thread.BalancingThreadPoolExecutor

shutdownNow() - Method in class com.github.rholder.moar.concurrent.thread.BalancingThreadPoolExecutor

size() - Method in class com.github.rholder.moar.concurrent.WrappedBlockingQueue

StrategicBlockingQueue<E> - Class in com.github.rholder.moar.concurrent

A StrategicBlockingQueue wraps a standard BlockingQueue, providing a QueueingStrategy for performing actions before and after adding and removing items from the wrapped queue.

StrategicBlockingQueue(BlockingQueue<E>, QueueingStrategy<E>) - Constructor for class com.github.rholder.moar.concurrent.StrategicBlockingQueue

StrategicExecutors - Class in com.github.rholder.moar.concurrent

Provide some convenience functions for creating new BalancingThreadPoolExecutor instances.

StrategicExecutors() - Constructor for class com.github.rholder.moar.concurrent.StrategicExecutors

StrategicQueues - Class in com.github.rholder.moar.concurrent

This is a helper class for instantiating StrategicBlockingQueue's.

StrategicQueues() - Constructor for class com.github.rholder.moar.concurrent.StrategicQueues

T

take() - Method in class com.github.rholder.moar.concurrent.StrategicBlockingQueue

take() - Method in class com.github.rholder.moar.concurrent.WrappedBlockingQueue

ThreadProfiler - Interface in com.github.rholder.moar.concurrent.thread

Implementations of this interface provide Thread profiling information.

toArray() - Method in class com.github.rholder.moar.concurrent.WrappedBlockingQueue

toArray(T[]) - Method in class com.github.rholder.moar.concurrent.WrappedBlockingQueue

Tracking - Class in com.github.rholder.moar.concurrent.thread

Collect tracking statistics for a given worker thread.

Tracking() - Constructor for class com.github.rholder.moar.concurrent.thread.Tracking

W

WrappedBlockingQueue<E> - Class in com.github.rholder.moar.concurrent

This is a pass-through class that just wraps all the methods of a BlockingQueue.

WrappedBlockingQueue(BlockingQueue<E>) - Constructor for class com.github.rholder.moar.concurrent.WrappedBlockingQueue

A B C D E G H I M N O P Q R S T W