Package 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	Description
ResettableBarrier()

Method Summary

Modifier and Type	Method	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 Details

ResettableBarrier

public ResettableBarrier()

Method Details

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()