|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.ow2.bonita.pvm.internal.jobexecutor.JobExecutor
public class JobExecutor
manager for jobImpl execution threads and their configuration.
Constructor Summary | |
---|---|
JobExecutor()
|
Method Summary | |
---|---|
Command<java.util.Collection<java.lang.Long>> |
getAcquireJobsCommand()
|
CommandService |
getCommandExecutor()
|
DispatcherThread |
getDispatcherThread()
|
java.util.List<JobHistoryEntry> |
getHistory()
|
int |
getHistorySize()
|
protected static java.lang.String |
getHostName()
|
int |
getIdleMillis()
|
int |
getIdleMillisMax()
|
protected java.util.concurrent.BlockingQueue<java.util.Collection<java.lang.Long>> |
getJobDbidsQueue()
|
int |
getLockMillis()
|
java.lang.String |
getName()
|
int |
getNbrOfThreads()
|
Command<java.util.Date> |
getNextDueDateCommand()
|
boolean |
isActive()
|
void |
jobWasAdded()
|
void |
setCommandExecutor(CommandService commandService)
|
void |
setHistoryMaxSize(int historyMaxSize)
|
void |
setIdleInterval(int idleInterval)
|
void |
setMaxIdleInterval(int maxIdleInterval)
|
void |
setMaxLockTime(int maxLockTime)
|
void |
setName(java.lang.String name)
|
void |
setNbrOfJobExecutorThreads(int nbrOfJobExecutorThreads)
|
void |
start()
starts the DispatcherThread and JobExecutorThread s for this
jobImpl executor |
void |
stop()
stops with join set to false. |
void |
stop(boolean join)
signals to all threads managed by this jobImpl executor to stop. |
protected void |
waitTillQueueEmpty()
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public JobExecutor()
Method Detail |
---|
public void start()
DispatcherThread
and JobExecutorThread
s for this
jobImpl executor
public void stop()
stop(boolean)
public void stop(boolean join)
protected void waitTillQueueEmpty()
public void jobWasAdded()
protected static java.lang.String getHostName()
protected java.util.concurrent.BlockingQueue<java.util.Collection<java.lang.Long>> getJobDbidsQueue()
public java.lang.String getName()
public int getHistorySize()
public int getIdleMillis()
public boolean isActive()
public int getIdleMillisMax()
public int getLockMillis()
public int getNbrOfThreads()
public CommandService getCommandExecutor()
public Command<java.util.Collection<java.lang.Long>> getAcquireJobsCommand()
public Command<java.util.Date> getNextDueDateCommand()
public DispatcherThread getDispatcherThread()
public java.util.List<JobHistoryEntry> getHistory()
public void setCommandExecutor(CommandService commandService)
public void setName(java.lang.String name)
public void setNbrOfJobExecutorThreads(int nbrOfJobExecutorThreads)
public void setIdleInterval(int idleInterval)
public void setMaxIdleInterval(int maxIdleInterval)
public void setHistoryMaxSize(int historyMaxSize)
public void setMaxLockTime(int maxLockTime)
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |