| |
|
| java.lang.Object java.lang.Thread com.knowgate.scheduler.WorkerThread
WorkerThread | public class WorkerThread extends Thread (Code) | | Scheduled Job Worker Thread
author: Sergio Montoro Ten version: 1.0 |
getDelayMS | public int getDelayMS()(Code) | | |
getDelayMS | public void getDelayMS(int iMiliseconds)(Code) | | |
getProperty | public String getProperty(String sKey)(Code) | | Get Environment property from hipergate.cnf
Parameters: sKey - Property Name Property Value or null if not found |
getRunningTimeMS | public long getRunningTimeMS()(Code) | | |
halt | public void halt()(Code) | | Halt thread execution commiting all operations in course before stopping
If a thread is dead-locked by any reason halting it will not cause any effect.
halt() method only sends a signals to the each WokerThread telling it that must
finish pending operations and stop.
|
run | public void run()(Code) | | Process atoms obtained throught AtomConsumer
Each worker WorkerThread will enter an endless loop until the queue is empty
or an interrupt signal is received.
If an exception is thrown while creating of processing atoms the workerthread
will be aborted.
|
unregisterCallback | public boolean unregisterCallback(String sCallbackName)(Code) | | Unregister a thread callback object
Parameters: sCallbackName - Name of callback to be unregistered true if a callback with such name was found and unregistered,false otherwise |
|
|
|