public class LocalTaskExecutorThreadPool
extends java.lang.Object
SchedulerFactoryBean.setTaskExecutor(java.util.concurrent.Executor)
Modifier and Type | Field and Description |
---|---|
protected Log |
logger
Logger available to subclasses
|
private java.util.concurrent.Executor |
taskExecutor |
Constructor and Description |
---|
LocalTaskExecutorThreadPool() |
Modifier and Type | Method and Description |
---|---|
int |
blockForAvailableThreads() |
int |
getPoolSize() |
void |
initialize() |
boolean |
runInThread(java.lang.Runnable runnable) |
void |
setInstanceId(java.lang.String schedInstId) |
void |
setInstanceName(java.lang.String schedName) |
void |
shutdown(boolean waitForJobsToComplete) |
protected final Log logger
private java.util.concurrent.Executor taskExecutor
public void setInstanceId(java.lang.String schedInstId)
public void setInstanceName(java.lang.String schedName)
public void initialize() throws SchedulerConfigException
SchedulerConfigException
public void shutdown(boolean waitForJobsToComplete)
public int getPoolSize()
public boolean runInThread(java.lang.Runnable runnable)
public int blockForAvailableThreads()