public void finished ( final ProcessorGraphNode processorGraphNode ) { this . processorLock . lock ( ) ; try { this . runningProcessors . remove ( processorGraphNode . getProcessor ( ) ) ; this . executedProcessors . put ( processorGraphNode . getProcessor ( ) , null ) ; } finally { this . processorLock . unlock ( ) ; } }
Flag that the processor has completed execution .