public void shutdownBlocking ( ) throws InterruptedException { executor . shutdown ( ) ; executor . awaitTermination ( ) ; allocator . shutdown ( ) ; allocator . awaitTermination ( ) ; }
Shuts down the threads used by the commit log blocking until completion .