METHOD_0 ( ) { final int IDENT_0 = INT_0 ; final int IDENT_1 = INT_1 ; final int IDENT_2 = INT_2 ; final java . util . concurrent . IDENT_3 < java . lang . String > input = new java . util . concurrent . METHOD_1 ( ) ; final org . apache . IDENT_4 . IDENT_5 . IDENT_6 . IDENT_7 IDENT_8 = org . apache . IDENT_4 . IDENT_5 . IDENT_6 . IDENT_7 . METHOD_2 ( new org . apache . IDENT_4 . IDENT_5 . IDENT_6 . IDENT_9 . METHOD_3 ( ) , input , IDENT_2 ) ; new java . lang . Thread ( new java . lang . METHOD_4 ( ) { @ org . apache . IDENT_4 . IDENT_5 . IDENT_6 . Override public void run ( ) { try { for ( int i = 1 ; i <= IDENT_0 ; i ++ ) { input . put ( "test" ) ; if ( ( i OP_0 IDENT_1 ) == 0 ) { input . put ( org . apache . IDENT_4 . IDENT_5 . IDENT_6 . IDENT_9 . METHOD_3 . IDENT_10 ) ; } } input . put ( org . apache . IDENT_4 . IDENT_5 . IDENT_6 . IDENT_9 . METHOD_3 . IDENT_11 ) ; } catch ( java . lang . IDENT_12 e ) { org . apache . IDENT_4 . IDENT_5 . IDENT_6 . IDENT_9 . logger . warn ( ( STRING_0 + e ) ) ; } } } ) . start ( ) ; final java . util . concurrent . atomic . IDENT_13 IDENT_14 = new java . util . concurrent . atomic . METHOD_5 ( 0 ) ; final java . util . concurrent . atomic . METHOD_5 IDENT_15 = new java . util . concurrent . atomic . METHOD_5 ( 0 ) ; while ( true ) { if ( IDENT_8 . METHOD_6 ( ) ) { break ; } IDENT_15 . METHOD_7 ( ) ; java . lang . Thread consumer = new java . lang . Thread ( new java . lang . METHOD_4 ( ) { @ org . apache . IDENT_4 . IDENT_5 . IDENT_6 . Override public void run ( ) { while ( IDENT_8 . hasNext ( ) ) { IDENT_8 . next ( ) ; IDENT_14 . METHOD_7 ( ) ; } System . out . println ( ( ( ( IDENT_14 . get ( ) ) + STRING_1 ) + ( IDENT_15 . get ( ) ) ) ) ; } } ) ; consumer . start ( ) ; try { consumer . join ( ) ; } catch ( java . lang . IDENT_12 e ) { org . apache . IDENT_4 . IDENT_5 . IDENT_6 . IDENT_9 . logger . warn ( ( STRING_2 + e ) ) ; } } "<AssertPlaceHolder>" ; } get ( ) { return this . conf ; }
org . junit . Assert . assertEquals ( IDENT_0 , IDENT_14 . get ( ) )