Package org.camunda.bpm.container.impl.jboss.service

Class MscExecutorService

java.lang.Object

org.camunda.bpm.container.impl.jboss.service.MscExecutorService

All Implemented Interfaces:

ExecutorService, org.jboss.msc.Service, org.jboss.msc.service.Service<MscExecutorService>, org.jboss.msc.value.Value<MscExecutorService>

public class MscExecutorService
extends Object
implements org.jboss.msc.service.Service<MscExecutorService>, ExecutorService

Field Summary

Fields

Modifier and Type	Field	Description
protected final Supplier<org.jboss.as.threads.ManagedQueueExecutorService>	managedQueueSupplier
protected final Consumer<ExecutorService>	provider

Fields inherited from interface org.jboss.msc.service.Service

NULL

Constructor Summary

Constructors

Constructor	Description
MscExecutorService(Supplier<org.jboss.as.threads.ManagedQueueExecutorService> managedQueueSupplier, Consumer<ExecutorService> provider)

Method Summary

Modifier and Type	Method	Description
Runnable	getExecuteJobsRunnable(List<String> jobIds, ProcessEngineImpl processEngine)	Returns a runnable to be used for executing Jobs.
MscExecutorService	getValue()
boolean	schedule(Runnable runnable, boolean isLongRunning)	Passes a Runnable to the runtime container for execution.
protected boolean	scheduleLongRunningWork(Runnable runnable)
protected boolean	scheduleShortRunningWork(Runnable runnable)
void	start(org.jboss.msc.service.StartContext context)
void	stop(org.jboss.msc.service.StopContext context)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

managedQueueSupplier

protected final Supplier<org.jboss.as.threads.ManagedQueueExecutorService> managedQueueSupplier

provider

protected final Consumer<ExecutorService> provider

Constructor Details

MscExecutorService

public MscExecutorService(Supplier<org.jboss.as.threads.ManagedQueueExecutorService> managedQueueSupplier,
 Consumer<ExecutorService> provider)

Method Details

getValue

public MscExecutorService getValue()
                            throws IllegalStateException,
IllegalArgumentException

Specified by:

getValue in interface org.jboss.msc.value.Value<MscExecutorService>

Throws:

IllegalStateException

IllegalArgumentException

start

public void start(org.jboss.msc.service.StartContext context)
           throws org.jboss.msc.service.StartException

Specified by:

start in interface org.jboss.msc.Service

Throws:

org.jboss.msc.service.StartException

stop

public void stop(org.jboss.msc.service.StopContext context)

Specified by:

stop in interface org.jboss.msc.Service

getExecuteJobsRunnable

public Runnable getExecuteJobsRunnable(List<String> jobIds,
 ProcessEngineImpl processEngine)

Description copied from interface: ExecutorService

Returns a runnable to be used for executing Jobs.

Specified by:

getExecuteJobsRunnable in interface ExecutorService

Returns:

schedule

public boolean schedule(Runnable runnable,
 boolean isLongRunning)

Description copied from interface: ExecutorService

Passes a Runnable to the runtime container for execution. Some runtime containers (like a Java EE container offer container provided infrastructure for executing background work (such as a JCA WorkManager). This method allows the process engine to take advantage of container infrastructure for doing background work.

Specified by:

schedule in interface ExecutorService

Parameters:

runnable - the Runnable to be executed.

isLongRunning - indicates whether the runnable is a daemon.

Returns:

true if the runnable could be successfully scheduled for execution. 'false' otherwise.

scheduleShortRunningWork

protected boolean scheduleShortRunningWork(Runnable runnable)

scheduleLongRunningWork

protected boolean scheduleLongRunningWork(Runnable runnable)