protected void awaitTasksTermination ( ) { delegated . shutdown ( ) ; try { delegated . awaitTermination ( Long . MAX_VALUE , TimeUnit . NANOSECONDS ) ; } catch ( InterruptedException e ) { LOG . warn ( "Termination has been interrupted" ) ; } }
Awaits until all tasks will be done .