METHOD_0 ( ) { int IDENT_0 = 10 ; final java . util . concurrent . atomic . IDENT_1 < java . lang . Exception > exception = new java . util . concurrent . atomic . METHOD_1 ( ) ; java . util . concurrent . IDENT_2 IDENT_3 = new java . util . concurrent . METHOD_2 ( ( IDENT_0 * 2 ) ) ; for ( int i = 0 ; i < IDENT_0 ; i ++ ) { com . IDENT_4 . IDENT_5 . redis . IDENT_6 . IDENT_7 IDENT_8 = new com . IDENT_4 . IDENT_5 . redis . IDENT_6 . impl . METHOD_3 ( channel , IDENT_9 ) ; IDENT_10 = new com . IDENT_4 . IDENT_5 . redis . IDENT_6 . impl . METHOD_4 ( IDENT_8 ) ; IDENT_11 . execute ( new java . lang . METHOD_5 ( ) { @ com . IDENT_4 . IDENT_5 . redis . IDENT_6 . impl . Override public void run ( ) { try { IDENT_10 . close ( 50 ) ; } catch ( java . lang . Exception e ) { logger . error ( STRING_0 , e ) ; exception . set ( e ) ; } finally { IDENT_3 . METHOD_6 ( ) ; } } } ) ; IDENT_11 . execute ( new java . lang . METHOD_5 ( ) { @ com . IDENT_4 . IDENT_5 . redis . IDENT_6 . impl . Override public void run ( ) { try { sleep ( 3 ) ; IDENT_10 . METHOD_7 ( ) ; } finally { IDENT_3 . METHOD_6 ( ) ; } } } ) ; } IDENT_3 . METHOD_8 ( 5 , TimeUnit . IDENT_12 ) ; "<AssertPlaceHolder>" ; } get ( ) { METHOD_8 ( ) ; java . lang . Throwable IDENT_13 = METHOD_9 ( ) ; if ( METHOD_9 == null ) { return METHOD_10 ( ) ; } if ( METHOD_9 instanceof com . IDENT_4 . IDENT_5 . command . IDENT_14 ) { throw ( ( com . IDENT_4 . IDENT_5 . command . IDENT_14 ) ( METHOD_9 ) ) ; } throw new com . IDENT_4 . IDENT_5 . command . METHOD_11 ( METHOD_9 ) ; }
org . junit . Assert . assertNull ( exception . get ( ) )