METHOD_0 ( ) { final java . util . concurrent . atomic . IDENT_0 IDENT_1 = new java . util . concurrent . atomic . METHOD_1 ( true ) ; final java . util . concurrent . atomic . METHOD_1 IDENT_2 = new java . util . concurrent . atomic . METHOD_1 ( false ) ; final java . util . IDENT_3 < java . lang . Integer > queue = METHOD_2 ( ) ; java . lang . Thread p = new java . lang . Thread ( ) { @ org . IDENT_4 . IDENT_5 . Override public void run ( ) { int i = 0 ; try { while ( IDENT_1 . get ( ) ) { if ( queue . isEmpty ( ) ) { queue . METHOD_3 ( ( i ++ ) ) ; queue . METHOD_3 ( ( i ++ ) ) ; queue . METHOD_3 ( ( i ++ ) ) ; } } } catch ( java . lang . Exception e ) { e . printStackTrace ( ) ; IDENT_2 . set ( true ) ; IDENT_1 . set ( false ) ; } } } ; java . lang . Thread c = new java . lang . Thread ( ) { @ org . IDENT_4 . IDENT_5 . Override public void run ( ) { int i = 0 ; try { while ( IDENT_1 . get ( ) ) { if ( ! ( queue . isEmpty ( ) ) ) { if ( ! ( queue . remove ( i ) ) ) { IDENT_2 . set ( true ) ; IDENT_1 . set ( false ) ; } i ++ ; } } } catch ( java . lang . Exception e ) { e . printStackTrace ( ) ; IDENT_2 . set ( true ) ; IDENT_1 . set ( false ) ; } } } ; p . start ( ) ; c . start ( ) ; java . util . concurrent . IDENT_6 . IDENT_7 . METHOD_4 ( TimeUnit . IDENT_8 . METHOD_5 ( INT_0 ) ) ; IDENT_1 . set ( false ) ; p . join ( ) ; c . join ( ) ; "<AssertPlaceHolder>" ; } get ( ) { long result = 0L ; long [ ] IDENT_9 = this . IDENT_9 ; int length = ( IDENT_10 ) + 1 ; for ( int i = 0 ; i < length ; i ++ ) { result += org . IDENT_4 . IDENT_11 . IDENT_12 . METHOD_6 ( IDENT_9 , METHOD_7 ( i ) ) ; } return result ; }
org . junit . Assert . assertFalse ( IDENT_2 . get ( ) )