public class BARRIER extends Protocol implements BARRIERMBean
| Modifier and Type | Method and Description |
|---|---|
void |
attachProtocol(Protocol p) |
int |
getInFlightThreadsCount()
Returns the current count of in-flight threads.
|
long |
getMaxCloseTime()
Gets configured max_close_time value (ms).
|
boolean |
isClosed()
Indicates if barrier is currently closed.
|
boolean |
isOpenerScheduled()
Returns true if barrier_opener_future is non-null.
|
create, destroy, dumpStats, getName, getPropertiesAsString, getStatsEnabled, printStats, resetStats, setProperties, setStatsEnabled, start, stopclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitcreate, destroy, dumpStats, getName, getPropertiesAsString, getStatsEnabled, printStats, resetStats, setProperties, setStatsEnabled, start, stoppublic BARRIER()
public BARRIER(Protocol p)
public void attachProtocol(Protocol p)
attachProtocol in class Protocolpublic int getInFlightThreadsCount()
BARRIERMBeanIn-flight threads are those currently processing in higher-level protocols.
getInFlightThreadsCount in interface BARRIERMBeanpublic long getMaxCloseTime()
BARRIERMBeangetMaxCloseTime in interface BARRIERMBeanpublic boolean isClosed()
BARRIERMBeanisClosed in interface BARRIERMBeanpublic boolean isOpenerScheduled()
BARRIERMBeanisOpenerScheduled in interface BARRIERMBeanCopyright ? 1998-2008 Bela Ban. All Rights Reserved.