@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(org.osgi.service.component.ComponentContext context) |
protected void |
deactivate(org.osgi.service.component.ComponentContext context) |
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
protected void activate(org.osgi.service.component.ComponentContext context)
protected void deactivate(org.osgi.service.component.ComponentContext context)
public void queueForExecution(Runnable inputJob)
ExecutionEngine
queueForExecution
in interface ExecutionEngine
public JobStatus getJobStatus(String path)
ExecutionEngine
getJobStatus
in interface ExecutionEngine
public Iterator<JobStatus> getMatchingJobStatus(Predicate<JobStatus> p)
ExecutionEngine
getMatchingJobStatus
in interface ExecutionEngine
p
- if null, returns all known JobStatus.Copyright © 2007–2015 The Apache Software Foundation. All rights reserved.