public T getRunner ( ) throws PipelineRuntimeException { validateNotDestroyed ( ) ; try { return queue . take ( ) . runner ; } catch ( InterruptedException e ) { throw new PipelineRuntimeException ( ContainerError . CONTAINER_0801 , e ) ; } finally { runtimeStats . setAvailableRunners ( queue . size ( ) ) ; histogram . update ( queue . size ( ) ) ; } }
Get exclusive runner for use .