org.apache.drill.exec.rpc

Class ResettableBarrier

java.lang.Object

org.apache.drill.exec.rpc.ResettableBarrier

public class ResettableBarrier
extends Object

Modified implementation of countdown latch that allows a barrier to be unilaterally opened and closed. All others simply wait when it is closed. Is initialized in a closed state.

Constructor Summary

Constructors

Constructor and Description
ResettableBarrier()

Method Summary

Modifier and Type	Method and Description
void	await()
boolean	await(long timeout, TimeUnit unit)
void	closeBarrier()
void	openBarrier()

Methods inherited from class java.lang.Object

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

Constructor Detail

ResettableBarrier

public ResettableBarrier()

Method Detail

await

public void await()
           throws InterruptedException

Throws:

InterruptedException

await

public boolean await(long timeout,
                     TimeUnit unit)
              throws InterruptedException

Throws:

InterruptedException

openBarrier

public void openBarrier()

closeBarrier

public void closeBarrier()