@Service public class ExecutionEngineImpl extends Object implements ExecutionEngine
| Modifier and Type | Class and Description |
|---|---|
static class |
ExecutionEngineImpl.QueueFullException |
| Modifier and Type | Field and Description |
|---|---|
static String |
PROP_CORE_POOL_SIZE |
static String |
PROP_KEEP_ALIVE_TIME |
static String |
PROP_MAX_POOL_SIZE |
| Constructor and Description |
|---|
ExecutionEngineImpl() |
| Modifier and Type | Method and Description |
|---|---|
protected void |
activate(Map<String,Object> props) |
protected void |
deactivate() |
JobStatus |
getJobStatus(String path)
Get JobStatus by path
|
Iterator<JobStatus> |
getMatchingJobStatus(Predicate<JobStatus> p)
Enumerate JobStatus that match supplied predicate
|
void |
queueForExecution(Runnable inputJob)
Add a job to the execution queue
|
@Property(intValue=10) public static final String PROP_CORE_POOL_SIZE
@Property(intValue=20) public static final String PROP_MAX_POOL_SIZE
@Property(intValue=30) public static final String PROP_KEEP_ALIVE_TIME
@Deactivate protected void deactivate()
public void queueForExecution(Runnable inputJob)
ExecutionEnginequeueForExecution in interface ExecutionEnginepublic JobStatus getJobStatus(String path)
ExecutionEnginegetJobStatus in interface ExecutionEnginepublic Iterator<JobStatus> getMatchingJobStatus(Predicate<JobStatus> p)
ExecutionEnginegetMatchingJobStatus in interface ExecutionEnginep - if null, returns all known JobStatus.Copyright © 2007–2016 The Apache Software Foundation. All rights reserved.