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-2021 Apache Software Foundation. All Rights Reserved.