public class SemaphoreValve extends ValveBase
Implementation of a Valve that limits concurrency.
This Valve may be attached to any Container, depending on the granularity of the concurrency control you wish to perform. Note that internally, some async requests may require multiple serial requests to complete what - to the user - appears as a single request.
| Modifier and Type | Field and Description |
|---|---|
protected boolean |
block
Block until a permit is available.
|
protected int |
concurrency
Concurrency level of the semaphore.
|
protected boolean |
fairness
Fairness of the semaphore.
|
protected boolean |
interruptible
Block interruptibly until a permit is available.
|
protected Semaphore |
semaphore
Semaphore.
|
asyncSupported, container, containerLog, next, smmserverAFTER_DESTROY_EVENT, AFTER_INIT_EVENT, AFTER_START_EVENT, AFTER_STOP_EVENT, BEFORE_DESTROY_EVENT, BEFORE_INIT_EVENT, BEFORE_START_EVENT, BEFORE_STOP_EVENT, CONFIGURE_START_EVENT, CONFIGURE_STOP_EVENT, PERIODIC_EVENT, START_EVENT, STOP_EVENT| Constructor and Description |
|---|
SemaphoreValve() |
| Modifier and Type | Method and Description |
|---|---|
boolean |
controlConcurrency(Request request,
Response response)
Subclass friendly method to add conditions.
|
boolean |
getBlock() |
int |
getConcurrency() |
boolean |
getFairness() |
boolean |
getInterruptible() |
void |
invoke(Request request,
Response response)
Do concurrency control on the request using the semaphore.
|
void |
permitDenied(Request request,
Response response)
Subclass friendly method to add error handling when a permit isn't
granted.
|
void |
setBlock(boolean block) |
void |
setConcurrency(int concurrency) |
void |
setFairness(boolean fairness) |
void |
setInterruptible(boolean interruptible) |
protected void |
startInternal()
Start this component and implement the requirements
of
LifecycleBase.startInternal(). |
protected void |
stopInternal()
Stop this component and implement the requirements
of
LifecycleBase.stopInternal(). |
backgroundProcess, event, getContainer, getDomainInternal, getNext, getObjectNameKeyProperties, initInternal, isAsyncSupported, setAsyncSupported, setContainer, setNext, toStringdestroyInternal, getDomain, getObjectName, postDeregister, postRegister, preDeregister, preRegister, register, setDomain, unregisteraddLifecycleListener, destroy, findLifecycleListeners, fireLifecycleEvent, getState, getStateName, init, removeLifecycleListener, setState, setState, start, stopprotected Semaphore semaphore
protected int concurrency
protected boolean fairness
protected boolean block
protected boolean interruptible
public int getConcurrency()
public void setConcurrency(int concurrency)
public boolean getFairness()
public void setFairness(boolean fairness)
public boolean getBlock()
public void setBlock(boolean block)
public boolean getInterruptible()
public void setInterruptible(boolean interruptible)
protected void startInternal()
throws LifecycleException
LifecycleBase.startInternal().startInternal in class ValveBaseLifecycleException - if this component detects a fatal error
that prevents this component from being usedprotected void stopInternal()
throws LifecycleException
LifecycleBase.stopInternal().stopInternal in class ValveBaseLifecycleException - if this component detects a fatal error
that prevents this component from being usedpublic void invoke(Request request, Response response) throws IOException, ServletException
invoke in interface Valveinvoke in class ValveBaserequest - The servlet request to be processedresponse - The servlet response to be createdIOException - if an input/output error occursServletException - if a servlet error occurspublic boolean controlConcurrency(Request request, Response response)
request - response - public void permitDenied(Request request, Response response) throws IOException, ServletException
request - response - IOExceptionServletExceptionCopyright © 2000-2014 Apache Software Foundation. All Rights Reserved.