Class ExtendedLatch

java.lang.Object
java.util.concurrent.CountDownLatch
org.apache.drill.common.concurrent.ExtendedLatch

public class ExtendedLatch extends CountDownLatch
An extended CountDownLatch which allows us to await uninterruptibly.
  • 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.