public class SharedExecutorServiceAsyncExecutor extends DefaultAsyncJobExecutor implements TenantAwareAsyncExecutor
AsyncExecutor.
For each tenant, there will be acquire threads, but only one ExecutorService will be used
once the jobs are acquired.| Modifier and Type | Field and Description |
|---|---|
protected Map<String,TenantAwareAcquireAsyncJobsDueRunnable> |
asyncJobAcquisitionRunnables |
protected Map<String,Thread> |
asyncJobAcquisitionThreads |
protected TenantInfoHolder |
tenantInfoHolder |
protected Map<String,TenantAwareAcquireTimerJobsRunnable> |
timerJobAcquisitionRunnables |
protected Map<String,Thread> |
timerJobAcquisitionThreads |
asyncJobAcquisitionThread, asyncJobLockTimeInMillis, asyncJobsDueRunnable, commandExecutor, corePoolSize, defaultAsyncJobAcquireWaitTimeInMillis, defaultTimerJobAcquireWaitTimeInMillis, executeAsyncRunnableFactory, executorService, isActive, isAutoActivate, keepAliveTime, lockOwner, maxAsyncJobsDuePerAcquisition, maxPoolSize, maxTimerJobsPerAcquisition, queueSize, retryWaitTimeInMillis, secondsToWaitOnShutdown, temporaryJobQueue, threadPoolQueue, timerJobAcquisitionThread, timerJobRunnable, timerLockTimeInMillis| Constructor and Description |
|---|
SharedExecutorServiceAsyncExecutor(TenantInfoHolder tenantInfoHolder) |
| Modifier and Type | Method and Description |
|---|---|
void |
addTenantAsyncExecutor(String tenantId,
boolean startExecutor) |
protected void |
startAsyncJobAcquisitionForTenant(String tenantId) |
protected void |
startJobAcquisitionThread()
Starts the acquisition thread
|
protected void |
startTimerJobAcquisitionForTenant(String tenantId) |
protected void |
stopJobAcquisitionThread()
Stops the acquisition thread
|
executeAsyncJob, getAsyncJobLockTimeInMillis, getCommandExecutor, getCorePoolSize, getDefaultAsyncJobAcquireWaitTimeInMillis, getDefaultTimerJobAcquireWaitTimeInMillis, getExecuteAsyncRunnableFactory, getExecutorService, getKeepAliveTime, getLockOwner, getMaxAsyncJobsDuePerAcquisition, getMaxPoolSize, getMaxTimerJobsPerAcquisition, getQueueSize, getRetryWaitTimeInMillis, getSecondsToWaitOnShutdown, getThreadPoolQueue, getTimerLockTimeInMillis, isActive, isAutoActivate, setAsyncJobLockTimeInMillis, setAsyncJobsDueRunnable, setAutoActivate, setCommandExecutor, setCorePoolSize, setDefaultAsyncJobAcquireWaitTimeInMillis, setDefaultTimerJobAcquireWaitTimeInMillis, setExecuteAsyncRunnableFactory, setExecutorService, setKeepAliveTime, setLockOwner, setMaxAsyncJobsDuePerAcquisition, setMaxPoolSize, setMaxTimerJobsPerAcquisition, setQueueSize, setRetryWaitTimeInMillis, setSecondsToWaitOnShutdown, setThreadPoolQueue, setTimerJobRunnable, setTimerLockTimeInMillis, shutdown, start, startExecutingAsyncJobs, stopExecutingAsyncJobsclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitexecuteAsyncJob, getAsyncJobLockTimeInMillis, getCommandExecutor, getDefaultAsyncJobAcquireWaitTimeInMillis, getDefaultTimerJobAcquireWaitTimeInMillis, getLockOwner, getMaxAsyncJobsDuePerAcquisition, getMaxTimerJobsPerAcquisition, getRetryWaitTimeInMillis, getTimerLockTimeInMillis, isActive, isAutoActivate, setAsyncJobLockTimeInMillis, setAutoActivate, setCommandExecutor, setDefaultAsyncJobAcquireWaitTimeInMillis, setDefaultTimerJobAcquireWaitTimeInMillis, setMaxAsyncJobsDuePerAcquisition, setMaxTimerJobsPerAcquisition, setRetryWaitTimeInMillis, setTimerLockTimeInMillis, shutdown, startprotected TenantInfoHolder tenantInfoHolder
protected Map<String,TenantAwareAcquireTimerJobsRunnable> timerJobAcquisitionRunnables
protected Map<String,TenantAwareAcquireAsyncJobsDueRunnable> asyncJobAcquisitionRunnables
public SharedExecutorServiceAsyncExecutor(TenantInfoHolder tenantInfoHolder)
public void addTenantAsyncExecutor(String tenantId, boolean startExecutor)
addTenantAsyncExecutor in interface TenantAwareAsyncExecutorprotected void startJobAcquisitionThread()
DefaultAsyncJobExecutorstartJobAcquisitionThread in class DefaultAsyncJobExecutorprotected void startTimerJobAcquisitionForTenant(String tenantId)
protected void startAsyncJobAcquisitionForTenant(String tenantId)
protected void stopJobAcquisitionThread()
DefaultAsyncJobExecutorstopJobAcquisitionThread in class DefaultAsyncJobExecutorCopyright © 2015 Alfresco. All rights reserved.