private class NodeTestTask.DefaultDynamicTestExecutor extends java.lang.Object implements Node.DynamicTestExecutor
| Modifier and Type | Field and Description |
|---|---|
private java.util.Map<UniqueId,NodeTestTask.DynamicTaskState> |
unfinishedTasks |
| Modifier | Constructor and Description |
|---|---|
private |
DefaultDynamicTestExecutor() |
| Modifier and Type | Method and Description |
|---|---|
void |
awaitFinished()
Block until all dynamic test descriptors submitted to this executor
are finished.
|
void |
execute(TestDescriptor testDescriptor)
Submit a dynamic test descriptor for immediate execution.
|
java.util.concurrent.Future<?> |
execute(TestDescriptor testDescriptor,
EngineExecutionListener executionListener)
Submit a dynamic test descriptor for immediate execution with a
custom, potentially no-op, execution listener.
|
private final java.util.Map<UniqueId,NodeTestTask.DynamicTaskState> unfinishedTasks
public void execute(TestDescriptor testDescriptor)
Node.DynamicTestExecutorexecute in interface Node.DynamicTestExecutortestDescriptor - the test descriptor to be executed; never
nullpublic java.util.concurrent.Future<?> execute(TestDescriptor testDescriptor, EngineExecutionListener executionListener)
Node.DynamicTestExecutorexecute in interface Node.DynamicTestExecutortestDescriptor - the test descriptor to be executed; never
nullexecutionListener - the executionListener to be notified; never
nullEngineExecutionListener.NOOPpublic void awaitFinished()
throws java.lang.InterruptedException
Node.DynamicTestExecutorThis method is useful if the node needs to perform actions in its
Node.execute(EngineExecutionContext, DynamicTestExecutor) method
after all its dynamic children have finished.
awaitFinished in interface Node.DynamicTestExecutorjava.lang.InterruptedException - if interrupted while waiting