METHOD_0 ( ) { METHOD_1 ( ) ; final java . util . concurrent . IDENT_0 IDENT_1 = new java . util . concurrent . METHOD_2 ( com . IDENT_2 . IDENT_3 . example . IDENT_4 . IDENT_5 . IDENT_6 ) ; com . IDENT_2 . IDENT_3 . IDENT_7 . api . IDENT_8 p = com . IDENT_2 . IDENT_3 . IDENT_7 . api . IDENT_8 . getInstance ( ) ; p . message ( STRING_0 , INT_0 ) . METHOD_3 ( STRING_1 ) . METHOD_4 ( STRING_2 ) . METHOD_5 ( ) . METHOD_6 ( ) ; long IDENT_9 = java . lang . System . currentTimeMillis ( ) ; for ( int i = 0 ; i < ( com . IDENT_2 . IDENT_3 . example . IDENT_4 . IDENT_5 . IDENT_6 ) ; i ++ ) { com . google . common . util . concurrent . IDENT_10 < com . IDENT_2 . IDENT_3 . core . result . IDENT_11 > future = ( ( com . google . common . util . concurrent . IDENT_10 < com . IDENT_2 . IDENT_3 . core . result . IDENT_11 > ) ( p . message ( STRING_0 , INT_0 ) . METHOD_3 ( STRING_1 ) . METHOD_4 ( STRING_2 ) . METHOD_5 ( ) . METHOD_6 ( ) ) ) ; future . METHOD_7 ( new java . lang . METHOD_8 ( ) { @ com . IDENT_2 . IDENT_3 . example . IDENT_4 . Override public void run ( ) { IDENT_1 . METHOD_9 ( ) ; } } , com . google . common . util . concurrent . IDENT_12 . METHOD_10 ( ) ) ; } boolean IDENT_13 = IDENT_1 . METHOD_11 ( INT_1 , TimeUnit . IDENT_14 ) ; "<AssertPlaceHolder>" ; long IDENT_15 = java . lang . System . currentTimeMillis ( ) ; METHOD_12 ( ( IDENT_15 - IDENT_9 ) ) ; } run ( ) { while ( true ) { try { org . IDENT_16 . tuple . IDENT_17 < java . lang . String , java . lang . String , java . lang . String > msg = queue . METHOD_13 ( ) ; METHOD_14 ( msg . METHOD_15 ( ) , msg . METHOD_16 ( ) , msg . METHOD_17 ( ) ) ; } catch ( java . lang . IDENT_18 e ) { e . printStackTrace ( ) ; } } }
org . junit . Assert . assertTrue ( IDENT_13 )