org.voovan.tools.bucket

Class LeakBucket

java.lang.Object

org.voovan.tools.bucket.Bucket

org.voovan.tools.bucket.LeakBucket

public class LeakBucket
extends Bucket

无锁漏桶

Field Summary

Fields inherited from class org.voovan.tools.bucket.Bucket

BUCKET_HASH_WHEEL_TIMER, hashWheelTask

Constructor Summary

Constructors

Constructor and Description
LeakBucket(int tokenSize, int interval) 令牌桶构造函数
LeakBucket(int tokenSize, int interval, int releaseTime) 令牌桶构造函数

Method Summary

Modifier and Type	Method and Description
boolean	acquire() 获取令牌, 立即返回
void	acquire(int timeout) 获取令牌, 带有时间等待
int	getReleaseTime()
void	init(int tokenSize, int interval, int releaseTime)
void	setReleaseTime(int releaseTime)

Methods inherited from class org.voovan.tools.bucket.Bucket

getHashWheelTask, release, setHashWheelTask

Methods inherited from class java.lang.Object

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

Constructor Detail

LeakBucket

public LeakBucket(int tokenSize,
                  int interval,
                  int releaseTime)

令牌桶构造函数

Parameters:

tokenSize - 漏桶的初始数量

interval - 漏桶的新增周期, 每次触发将重置漏桶的数量, 单位: 毫秒

releaseTime - 漏桶失效并自动移除的时间

LeakBucket

public LeakBucket(int tokenSize,
                  int interval)

令牌桶构造函数

Parameters:

tokenSize - 漏桶的初始数量

interval - 漏桶的新增周期, 每次触发将重置漏桶的数量, 单位: 毫秒

Method Detail

init

public void init(int tokenSize,
                 int interval,
                 int releaseTime)

getReleaseTime

public int getReleaseTime()

setReleaseTime

public void setReleaseTime(int releaseTime)

acquire

public boolean acquire()

获取令牌, 立即返回

Specified by:

acquire in class Bucket

Returns:

true: 拿到令牌, false: 没有拿到令牌

acquire

public void acquire(int timeout)
             throws TimeoutException

获取令牌, 带有时间等待

Specified by:

acquire in class Bucket

Parameters:

timeout - 等待时间

Throws:

TimeoutException - 超时异常