public void returnRunner ( T runner ) throws PipelineRuntimeException { validateNotDestroyed ( ) ; queue . add ( new QueueItem <> ( runner ) ) ; runtimeStats . setAvailableRunners ( queue . size ( ) ) ; histogram . update ( queue . size ( ) ) ; }
Return given runner back to the pool .