public class LocalTaskExecutorThreadPool
extends java.lang.Object
ThreadPool
adapter that delegates to a Spring-managed
Executor
instance, specified on SchedulerFactoryBean
.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
@Nullable 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()