org.apache.drill.common.concurrent

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 Summary

Constructors

Constructor and Description
ExtendedLatch()
ExtendedLatch(int count)

Method Summary

Modifier and Type	Method and Description
void	awaitUninterruptibly() Await without interruption.
boolean	awaitUninterruptibly(long waitMillis) Await without interruption for a given time.

Methods inherited from class java.util.concurrent.CountDownLatch

await, await, countDown, getCount, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

ExtendedLatch

public ExtendedLatch()

ExtendedLatch

public ExtendedLatch(int count)

Method Detail

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.