Class ExtendedLatch
java.lang.Object
java.util.concurrent.CountDownLatch
org.apache.drill.common.concurrent.ExtendedLatch
An extended CountDownLatch which allows us to await uninterruptibly.
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionvoid
Await without interruption.boolean
awaitUninterruptibly
(long waitMillis) Await without interruption for a given time.
-
Constructor Details
-
ExtendedLatch
public ExtendedLatch() -
ExtendedLatch
public ExtendedLatch(int count)
-
-
Method Details
-
awaitUninterruptibly
public boolean awaitUninterruptibly(long waitMillis) Await without interruption for a given time.- Parameters:
waitMillis
- Time in milliseconds to wait- Returns:
- Whether the countdown reached zero or not.
-
awaitUninterruptibly
public void awaitUninterruptibly()Await without interruption. In the case of interruption, log a warning and continue to wait.
-