|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.apache.cassandra.concurrent.StageManager
public class StageManager
This class manages executor services for Messages recieved: each Message requests running on a specific "stage" for concurrency control; hence the Map approach, even though stages (executors) are not created dynamically.
Field Summary | |
---|---|
static long |
KEEPALIVE
|
Constructor Summary | |
---|---|
StageManager()
|
Method Summary | |
---|---|
static java.util.concurrent.ThreadPoolExecutor |
getStage(Stage stage)
Retrieve a stage from the StageManager |
static void |
shutdownNow()
This method shuts down all registered stages. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
public static final long KEEPALIVE
Constructor Detail |
---|
public StageManager()
Method Detail |
---|
public static java.util.concurrent.ThreadPoolExecutor getStage(Stage stage)
stage
- name of the stage to be retrieved.public static void shutdownNow()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |