private void started ( final ProcessorGraphNode processorGraphNode ) { this . processorLock . lock ( ) ; try { this . runningProcessors . put ( processorGraphNode . getProcessor ( ) , null ) ; } finally { this . processorLock . unlock ( ) ; } }
Flag that the processor has started execution .