Class ProcessingCoordinator<I>

java.lang.Object
com.evolveum.midpoint.repo.common.activity.run.processing.ProcessingCoordinator<I>

public class ProcessingCoordinator<I> extends Object
Responsible for distributing instances of ItemProcessingRequest to individual worker threads.
  • Constructor Details

    • ProcessingCoordinator

      public ProcessingCoordinator(int threadsCount, @NotNull @NotNull IterativeActivityRun<I,?,?,?> activityRun)
  • Method Details

    • submit

      public boolean submit(ItemProcessingRequest<I> request, OperationResult result)
    • createWorkerThreads

      public void createWorkerThreads() throws ConfigurationException
      Throws:
      ConfigurationException
    • isMultithreaded

      public boolean isMultithreaded()
    • finishProcessing

      public 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). Acknowledges any pending requests.