Class ProcessingCoordinator<I>


  • public class ProcessingCoordinator<I>
    extends Object
    TODO
    • Method Detail

      • 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.