METHOD_0 ( ) { final java . util . concurrent . IDENT_0 IDENT_1 = new java . util . concurrent . METHOD_1 ( 1 ) ; final java . lang . Thread writer = new java . lang . Thread ( ) { @ org . apache . IDENT_2 . test . core . impl . IDENT_3 . Override public void run ( ) { service . write ( "test" , "value" ) ; IDENT_1 . METHOD_2 ( ) ; } } ; final java . util . concurrent . METHOD_1 end = new java . util . concurrent . METHOD_1 ( 1 ) ; final java . util . concurrent . atomic . IDENT_4 < java . lang . String > val = new java . util . concurrent . atomic . IDENT_4 < java . lang . String > ( ) ; final java . lang . Thread reader = new java . lang . Thread ( ) { @ org . apache . IDENT_2 . test . core . impl . IDENT_3 . Override public void run ( ) { try { IDENT_1 . METHOD_3 ( 1 , TimeUnit . IDENT_5 ) ; } catch ( final java . lang . IDENT_6 e ) { java . lang . Thread . METHOD_4 ( ) ; org . junit . Assert . fail ( ) ; } val . set ( service . read ( "test" ) ) ; end . METHOD_2 ( ) ; } } ; reader . start ( ) ; writer . start ( ) ; try { end . METHOD_3 ( 1 , TimeUnit . IDENT_5 ) ; } catch ( final java . lang . IDENT_6 e ) { java . lang . Thread . METHOD_4 ( ) ; org . junit . Assert . fail ( ) ; } "<AssertPlaceHolder>" ; } get ( ) { return IDENT_7 . get ( ) ; }
org . junit . Assert . assertEquals ( "value" , val . get ( ) )