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, stopExecutingAsyncJobs
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
executeAsyncJob, getAsyncJobLockTimeInMillis, getCommandExecutor, getDefaultAsyncJobAcquireWaitTimeInMillis, getDefaultTimerJobAcquireWaitTimeInMillis, getLockOwner, getMaxAsyncJobsDuePerAcquisition, getMaxTimerJobsPerAcquisition, getRetryWaitTimeInMillis, getTimerLockTimeInMillis, isActive, isAutoActivate, setAsyncJobLockTimeInMillis, setAutoActivate, setCommandExecutor, setDefaultAsyncJobAcquireWaitTimeInMillis, setDefaultTimerJobAcquireWaitTimeInMillis, setMaxAsyncJobsDuePerAcquisition, setMaxTimerJobsPerAcquisition, setRetryWaitTimeInMillis, setTimerLockTimeInMillis, shutdown, start
protected 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 TenantAwareAsyncExecutor
protected void startJobAcquisitionThread()
DefaultAsyncJobExecutor
startJobAcquisitionThread
in class DefaultAsyncJobExecutor
protected void startTimerJobAcquisitionForTenant(String tenantId)
protected void startAsyncJobAcquisitionForTenant(String tenantId)
protected void stopJobAcquisitionThread()
DefaultAsyncJobExecutor
stopJobAcquisitionThread
in class DefaultAsyncJobExecutor
Copyright © 2015 Alfresco. All rights reserved.