Class ProcessingCoordinator<I>
java.lang.Object
com.evolveum.midpoint.repo.common.activity.run.processing.ProcessingCoordinator<I>
Responsible for distributing instances of
ItemProcessingRequest
to individual worker threads.-
Constructor Summary
ConstructorDescriptionProcessingCoordinator
(int threadsCount, @NotNull IterativeActivityRun<I, ?, ?, ?> activityRun) -
Method Summary
Modifier and TypeMethodDescriptionvoid
void
finishProcessing
(OperationResult result) Tells the workers that they should not expect any more work and waits for their completion (which can occur either because of queue is empty or because canRun is false).boolean
boolean
submit
(ItemProcessingRequest<I> request, OperationResult result)
-
Constructor Details
-
ProcessingCoordinator
public ProcessingCoordinator(int threadsCount, @NotNull @NotNull IterativeActivityRun<I, ?, ?, ?> activityRun)
-
-
Method Details
-
submit
-
createWorkerThreads
- Throws:
ConfigurationException
-
isMultithreaded
public boolean isMultithreaded() -
finishProcessing
Tells the workers that they should not expect any more work and waits for their completion (which can occur either because of queue is empty or because canRun is false). Acknowledges any pending requests.
-