public class VersionBucket extends Object
lockTimeoutMs
.Modifier and Type | Class and Description |
---|---|
static interface |
VersionBucket.CheckedFunction<T,R> |
Modifier and Type | Field and Description |
---|---|
long |
highest |
Constructor and Description |
---|
VersionBucket() |
Modifier and Type | Method and Description |
---|---|
void |
awaitNanos(long nanosTimeout) |
<T,R> R |
runWithLock(int lockTimeoutMs,
VersionBucket.CheckedFunction<T,R> function)
This will run the function with the intrinsic object monitor.
|
void |
signalAll() |
void |
unlock()
Nothing to do for the intrinsic object monitor.
|
void |
updateHighest(long val) |
public void updateHighest(long val)
public <T,R> R runWithLock(int lockTimeoutMs, VersionBucket.CheckedFunction<T,R> function) throws IOException
IOException
public void unlock()
public void signalAll()
public void awaitNanos(long nanosTimeout)
Copyright © 2000-2019 Apache Software Foundation. All Rights Reserved.