public class Timing extends Object
Constructor and Description |
---|
Timing()
Use the default base time
|
Timing(double multiple)
Use a multiple of the default base time
|
Timing(double multiple,
int waitingMultiple)
Use a multiple of the default base time
|
Timing(long value,
TimeUnit unit) |
Timing(long value,
TimeUnit unit,
int waitingMultiple) |
Modifier and Type | Method and Description |
---|---|
boolean |
acquireSemaphore(Semaphore semaphore)
Wait on the given semaphore
|
boolean |
acquireSemaphore(Semaphore semaphore,
int n)
Wait on the given semaphore
|
boolean |
awaitLatch(CountDownLatch latch)
Wait on the given latch
|
int |
connection()
Return the value to use for ZK connection timeout
|
Timing |
forWaiting()
Return a new timing with the standard multiple for waiting on latches, etc.
|
int |
milliseconds()
Return the base time in milliseconds
|
Timing |
multiple(double n)
Return a new timing that is a multiple of the this timing
|
int |
seconds()
Return the base time in seconds
|
int |
session()
Return the value to use for ZK session timeout
|
void |
sleepABit()
Sleep for a small amount of time
|
public Timing()
public Timing(double multiple)
multiple
- the multiplepublic Timing(double multiple, int waitingMultiple)
multiple
- the multiplewaitingMultiple
- multiple of main timing to use when waitingpublic Timing(long value, TimeUnit unit)
value
- base timeunit
- base time unitpublic Timing(long value, TimeUnit unit, int waitingMultiple)
value
- base timeunit
- base time unitwaitingMultiple
- multiple of main timing to use when waitingpublic int milliseconds()
public int seconds()
public boolean awaitLatch(CountDownLatch latch)
latch
- latch to wait onCountDownLatch.await(long, TimeUnit)
public boolean acquireSemaphore(Semaphore semaphore)
semaphore
- the semaphoreSemaphore.tryAcquire()
public boolean acquireSemaphore(Semaphore semaphore, int n)
semaphore
- the semaphoren
- number of permits to acquireSemaphore.tryAcquire(int, long, TimeUnit)
public Timing multiple(double n)
n
- the multiplepublic Timing forWaiting()
public void sleepABit() throws InterruptedException
InterruptedException
- if interruptedpublic int session()
public int connection()
Copyright © 2011–2019 The Apache Software Foundation. All rights reserved.