com.github.akurilov.concurrent.throttle

Class SequentialWeightsThrottle

java.lang.Object

com.github.akurilov.concurrent.throttle.SequentialWeightsThrottle

All Implemented Interfaces:

IndexThrottle

public final class SequentialWeightsThrottle
extends java.lang.Object
implements IndexThrottle

Created by kurila on 29.03.16. An throttle which uses the map of weights. The throttle determines the weight for each I/O task and makes the decision. The weight is used to pass the I/O task with specific ratio for the different keys.

Constructor Summary

Constructors

Constructor and Description
SequentialWeightsThrottle(int[] weights)

Method Summary

Modifier and Type	Method and Description
boolean	tryAcquire(int index)
int	tryAcquire(int index, int times)

Methods inherited from class java.lang.Object

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

Constructor Detail

SequentialWeightsThrottle

public SequentialWeightsThrottle(int[] weights)
                          throws java.lang.IllegalArgumentException

Throws:

java.lang.IllegalArgumentException

Method Detail

tryAcquire

public final boolean tryAcquire(int index)

Specified by:

tryAcquire in interface IndexThrottle

tryAcquire

public final int tryAcquire(int index,
                            int times)

Specified by:

tryAcquire in interface IndexThrottle