public void fail ( ) { hasFailure = true ; // fail fast long count = latch . getCount ( ) ; for ( int i = 0 ; i < count ; i ++ ) { latch . countDown ( ) ; } }
Countdown and fail - fast if the sub message is failed .