@ Override public void initialize ( ) { Exceptions . checkNotClosed ( this . closed . get ( ) , this ) ; long traceId = LoggerHelpers . traceEnter ( log , "initialize" ) ; long containerCount = this . segmentToContainerMapper . getTotalContainerCount ( ) ; ArrayList < CompletableFuture < Void > > futures = new ArrayList <> ( ) ; for ( int containerId = 0 ; containerId < containerCount ; containerId ++ ) { futures . add ( this . registry . startContainer ( containerId , INIT_TIMEOUT_PER_CONTAINER ) . thenAccept ( this :: registerHandle ) ) ; } Futures . allOf ( futures ) . join ( ) ; LoggerHelpers . traceLeave ( log , "initialize" , traceId ) ; }
region SegmentContainerManager Implementation