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
IOExceptionpublic void unlock()
public void signalAll()
public void awaitNanos(long nanosTimeout)
Copyright © 2000-2020 Apache Software Foundation. All Rights Reserved.