Package org.apache.nifi.processors.standard

Class ControlRate.Throttle

java.lang.Object

java.util.concurrent.locks.ReentrantLock

org.apache.nifi.processors.standard.ControlRate.Throttle

All Implemented Interfaces:

Serializable, Lock

Enclosing class:

ControlRate

private static class ControlRate.Throttle
extends ReentrantLock

Field Summary

Fields

Modifier and Type	Field	Description
private final LongSupplier	currentTimeSupplier
private long	lastUpdateTime
private final org.apache.nifi.logging.ComponentLog	logger
private final AtomicLong	maxRate
private long	penalizationExpired
private long	penalizationPeriod
private final TimedBuffer<TimestampedLong>	timedBuffer
private final long	timePeriodMillis

Constructor Summary

Constructors

Modifier	Constructor	Description
private	Throttle(int timePeriod, TimeUnit unit, org.apache.nifi.logging.ComponentLog logger, LongSupplier currentTimeSupplier)

Method Summary

Modifier and Type	Method	Description
long	lastUpdateTime()
void	setMaxRate(long maxRate)
boolean	tryAdd(long value)

Methods inherited from class java.util.concurrent.locks.ReentrantLock

getHoldCount, getOwner, getQueuedThreads, getQueueLength, getWaitingThreads, getWaitQueueLength, hasQueuedThread, hasQueuedThreads, hasWaiters, isFair, isHeldByCurrentThread, isLocked, lock, lockInterruptibly, newCondition, toString, tryLock, tryLock, unlock

Methods inherited from class java.lang.Object

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

Field Details

maxRate

private final AtomicLong maxRate

timePeriodMillis

private final long timePeriodMillis

timedBuffer

private final TimedBuffer<TimestampedLong> timedBuffer

logger

private final org.apache.nifi.logging.ComponentLog logger

currentTimeSupplier

private final LongSupplier currentTimeSupplier

penalizationPeriod

private volatile long penalizationPeriod

penalizationExpired

private volatile long penalizationExpired

lastUpdateTime

private volatile long lastUpdateTime

Constructor Details

Throttle

private Throttle(int timePeriod,
 TimeUnit unit,
 org.apache.nifi.logging.ComponentLog logger,
 LongSupplier currentTimeSupplier)

Method Details

setMaxRate

public void setMaxRate(long maxRate)

lastUpdateTime

public long lastUpdateTime()

tryAdd

public boolean tryAdd(long value)