com.github.rholder.moar.concurrent

Class QueueingStrategies

java.lang.Object

com.github.rholder.moar.concurrent.QueueingStrategies

public class QueueingStrategies
extends java.lang.Object

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

Constructor Summary

Constructors

Constructor and Description
QueueingStrategies()

Method Summary

Methods

Modifier and Type	Method and Description
static <V> QueueingStrategy<V>	newHeapQueueingStrategy(double percentOfHeapBeforeFlowControl, long maxDelay, long dequeueHint) Construct a new HeapQueueingStrategy with the given parameters.

Methods inherited from class java.lang.Object

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

Constructor Detail

QueueingStrategies

public QueueingStrategies()

Method Detail

newHeapQueueingStrategy

public static <V> QueueingStrategy<V> newHeapQueueingStrategy(double percentOfHeapBeforeFlowControl,
                                              long maxDelay,
                                              long dequeueHint)

Construct a new HeapQueueingStrategy with the given parameters. For example, (0.85, 5000, 10000) translates to when 85% of heap is in use, start exponentially delaying additional enqueues up to a max of 5000 ms, garbage collecting after every 10000 dequeues to ensure that

Parameters:

percentOfHeapBeforeFlowControl - the percentage of the heap that must be available before the queue begins to start delaying addition operations

maxDelay - the maximum amount of time to delay an addition operation in milliseconds

dequeueHint - after this many dequeue operations, signal the JVM to run a garbage collection