|
Style Intelligence v12.0 | ||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||
java.lang.Objectinetsoft.sree.schedule.Scheduler
public class Scheduler
| Nested Class Summary | |
|---|---|
static class |
Scheduler.MulticastMessage
Representation of a mutlicast message. |
static class |
Scheduler.MulticastReceiveThread
Listener thread that handles incoming multicast messages. |
| Field Summary | |
|---|---|
inetsoft.util.DataChangeListener |
changeListener
Listener added to be notified if the file on disk has changed. |
static int |
HEARTBEAT_INTERVAL
Scheduler Multicast heartbeat interval. |
static int |
HEARTBEAT_MESSAGE
Scheduler Multicast heartbeat message identifier. |
static int |
LASTRUN_FAILED
Status: a task has finished with failure. |
static int |
LASTRUN_FINISHED
Status: a task has finished successfully. |
static int |
LASTRUN_INTERRUPTED
Status: a task is interrupted because of system restart |
static int |
LASTRUN_STARTED
Status: a task has been started. |
static int |
LOOPBACK_MESSAGE
Scheduler Multicast loopback message identifier. |
static int |
MESSAGE
Plain message. |
static String |
MULTICAST_ADDRESS
Scheduler Multicast address. |
static int |
MULTICAST_PORT
Scheduler Multicast port. |
static int |
NEXTRUN_DELETE
Status: a task mark to be removed later by the execution thread. |
static int |
NEXTRUN_IGNORED
Status: the task's conditions are currently not satisfied and there is not a known retest interval for the task, may be the condition trigger is not existed. |
static int |
NEXTRUN_PENDING
Status: the task's conditions needs to be retested at a known time interval. |
static int |
NEXTRUN_READY
Status: a task is ready to run, but not started because of concurrency limit. |
static int |
NEXTRUN_WAITTRIGGER
Status: the task's conditions are currently not satisfied and there is not a known retest interval for the task. |
static int |
PRIMARY_SEARCH_MESSAGE
Scheduler Multicast primary search message identifier. |
| Method Summary | |
|---|---|
String |
getID()
Get the id of the scheduler node. |
String |
getPrimaryID()
Get the id of the primary scheduler node. |
static Scheduler |
getScheduler()
Get the scheduler instance. |
boolean |
isPrimary()
Returns true of this is the primary scheduler and it should be run. |
boolean |
isRunning()
Determine if this scheduler instance is running. |
void |
restart()
|
void |
run()
Thread run method. |
static void |
runNow(String taskName)
Run the named task immediately. |
void |
setID(String identifier)
Set the unique identifier for this scheduler. |
void |
setPrimaryID(String pid)
Set the id of the primary scheduler. |
void |
setTaskReady(inetsoft.sree.schedule.Scheduler.TaskStatus taskStatus)
Initializes the thread pools, making a task ready to run. |
static void |
start()
Start running a scheduler thread. |
static void |
start(String id)
Start running a scheduler thread. |
static void |
stop()
Stop scheduler process. |
static void |
stopNow(String taskName)
Stop the named task. |
| Methods inherited from class java.lang.Object |
|---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
| Field Detail |
|---|
public static final int LASTRUN_STARTED
public static final int LASTRUN_FINISHED
public static final int LASTRUN_FAILED
public static final int LASTRUN_INTERRUPTED
public static final int NEXTRUN_PENDING
public static final int NEXTRUN_READY
public static final int NEXTRUN_IGNORED
public static final int NEXTRUN_WAITTRIGGER
public static final int NEXTRUN_DELETE
public static final int MESSAGE
public static final String MULTICAST_ADDRESS
public static final int MULTICAST_PORT
public static final int HEARTBEAT_INTERVAL
public static final int HEARTBEAT_MESSAGE
public static final int PRIMARY_SEARCH_MESSAGE
public static final int LOOPBACK_MESSAGE
public inetsoft.util.DataChangeListener changeListener
| Method Detail |
|---|
public static void start()
throws Exception
Exception
public static void start(String id)
throws Exception
Exception
public static void stop()
throws Exception
Exception
public static void runNow(String taskName)
throws Exception
Exception
public static void stopNow(String taskName)
throws Exception
Exceptionpublic static Scheduler getScheduler()
public void setID(String identifier)
public String getID()
public String getPrimaryID()
public void setPrimaryID(String pid)
public boolean isPrimary()
public void restart()
throws Exception
Exceptionpublic void run()
public void setTaskReady(inetsoft.sree.schedule.Scheduler.TaskStatus taskStatus)
taskStatus - Object which needs to be added to the queue.
Calling code should synchronize on the status parameter.public boolean isRunning()
true if the scheduler is running.
|
Copyright © 1996-2014 InetSoft Technology Corp. All Rights Reserved. | ||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||