METHOD_0 ( ) { java . lang . String name = STRING_0 ; final com . google . common . util . concurrent . IDENT_0 IDENT_1 = com . google . common . util . concurrent . IDENT_0 . create ( 1000 ) ; org . apache . IDENT_2 . IDENT_3 IDENT_4 = new org . apache . IDENT_2 . METHOD_1 ( ) ; IDENT_4 . METHOD_2 ( 0 ) ; IDENT_4 . METHOD_3 ( true ) ; org . apache . IDENT_2 . api . IDENT_5 IDENT_6 = METHOD_4 ( IDENT_4 , name ) ; final org . apache . IDENT_2 . api . IDENT_7 writer = IDENT_6 . METHOD_5 ( ) ; org . apache . IDENT_2 . util . Utils . METHOD_6 ( writer . write ( org . apache . IDENT_2 . IDENT_8 . METHOD_7 ( 0 ) ) ) ; org . apache . IDENT_2 . util . Utils . METHOD_6 ( writer . write ( org . apache . IDENT_2 . IDENT_8 . METHOD_7 ( 1 ) ) ) ; final java . util . concurrent . atomic . IDENT_9 IDENT_10 = new java . util . concurrent . atomic . METHOD_8 ( 2 ) ; org . apache . IDENT_2 . api . IDENT_5 IDENT_11 = METHOD_4 ( conf , name ) ; org . apache . IDENT_2 . IDENT_12 IDENT_13 = ( ( org . apache . IDENT_2 . IDENT_12 ) ( IDENT_11 . METHOD_9 ( 0 ) ) ) ; try { org . apache . IDENT_2 . IDENT_14 . IDENT_15 [ ] IDENT_16 = new org . apache . IDENT_2 . IDENT_14 . IDENT_15 [ 1 ] ; IDENT_16 [ 0 ] = new org . apache . IDENT_2 . IDENT_14 . METHOD_10 ( STRING_1 , IDENT_13 , false ) ; final java . util . concurrent . atomic . IDENT_17 IDENT_18 = new java . util . concurrent . atomic . METHOD_11 ( true ) ; java . lang . Thread IDENT_19 = new java . lang . Thread ( STRING_2 ) { @ org . apache . IDENT_2 . Override public void run ( ) { try { long IDENT_20 = 2 ; org . apache . IDENT_2 . IDENT_21 IDENT_22 = IDENT_21 . IDENT_23 ; while ( IDENT_18 . get ( ) ) { IDENT_1 . METHOD_12 ( ) ; long IDENT_24 = IDENT_20 ++ ; IDENT_22 = org . apache . IDENT_2 . util . Utils . METHOD_6 ( writer . write ( org . apache . IDENT_2 . IDENT_8 . METHOD_7 ( IDENT_24 ) ) ) ; IDENT_10 . METHOD_13 ( ) ; if ( ( IDENT_24 OP_0 1000 ) == 0 ) { org . apache . IDENT_2 . LOG . info ( STRING_3 , IDENT_24 ) ; } } org . apache . IDENT_2 . LOG . info ( STRING_4 , IDENT_22 ) ; org . apache . IDENT_2 . util . Utils . close ( writer ) ; } catch ( org . apache . IDENT_2 . exceptions . IDENT_25 IDENT_26 ) { java . lang . Thread . METHOD_14 ( ) . METHOD_15 ( ) ; } catch ( java . lang . Exception e ) { } } } ; for ( org . apache . IDENT_2 . IDENT_14 . METHOD_10 IDENT_27 : IDENT_16 ) { IDENT_27 . start ( ) ; } IDENT_19 . start ( ) ; TimeUnit . IDENT_28 . sleep ( 5 ) ; org . apache . IDENT_2 . LOG . info ( STRING_5 ) ; IDENT_18 . set ( false ) ; IDENT_19 . join ( ) ; org . apache . IDENT_2 . LOG . info ( STRING_6 , IDENT_10 . get ( ) ) ; while ( ( IDENT_10 . get ( ) ) > ( IDENT_16 [ 0 ] . METHOD_16 ( ) ) ) { org . apache . IDENT_2 . LOG . info ( STRING_7 , new java . lang . Object [ ] { IDENT_10 . get ( ) , IDENT_16 [ 0 ] . METHOD_16 ( ) } ) ; TimeUnit . IDENT_29 . sleep ( 100 ) ; } "<AssertPlaceHolder>" ; for ( org . apache . IDENT_2 . IDENT_14 . METHOD_10 IDENT_30 : IDENT_16 ) { IDENT_30 . METHOD_17 ( ) ; } } finally { IDENT_6 . close ( ) ; IDENT_13 . close ( ) ; IDENT_11 . close ( ) ; } } get ( ) { return IDENT_31 . get ( ) ; }
org . junit . Assert . assertEquals ( IDENT_10 . get ( ) , IDENT_16 [ 0 ] . METHOD_16 ( ) )