METHOD_0 ( ) { final int IDENT_0 = 1000 ; final java . util . concurrent . atomic . IDENT_1 IDENT_2 = new java . util . concurrent . atomic . METHOD_1 ( ) ; final java . util . concurrent . atomic . IDENT_3 < java . lang . Boolean > result = new java . util . concurrent . atomic . IDENT_3 < java . lang . Boolean > ( true ) ; final java . util . concurrent . IDENT_4 read = new java . util . concurrent . METHOD_2 ( 0 ) ; final java . util . concurrent . METHOD_2 write = new java . util . concurrent . METHOD_2 ( 1 ) ; final java . util . concurrent . atomic . IDENT_5 IDENT_6 = new java . util . concurrent . atomic . METHOD_3 ( false ) ; final java . util . concurrent . IDENT_7 IDENT_8 = new java . util . concurrent . METHOD_4 ( 2 ) ; IDENT_9 . execute ( new com . IDENT_10 . IDENT_11 . concurrent . METHOD_5 ( ) { @ com . IDENT_10 . IDENT_11 . redis . IDENT_12 . store . Override MOD_0 void METHOD_6 ( ) throws com . IDENT_10 . IDENT_11 . redis . IDENT_12 . store . Exception { try { for ( int i = 0 ; i < IDENT_0 ; i ++ ) { write . METHOD_7 ( ) ; int IDENT_13 = METHOD_8 ( 0 , ( 1 << 8 ) ) ; IDENT_14 . METHOD_9 ( io . netty . buffer . IDENT_15 . METHOD_10 ( METHOD_11 ( IDENT_13 ) . getBytes ( ) ) ) ; IDENT_2 . METHOD_12 ( IDENT_13 ) ; read . METHOD_13 ( ) ; } } finally { IDENT_6 . set ( true ) ; read . METHOD_13 ( ) ; IDENT_8 . METHOD_14 ( ) ; } } } ) ; IDENT_9 . execute ( new com . IDENT_10 . IDENT_11 . concurrent . METHOD_5 ( ) { @ com . IDENT_10 . IDENT_11 . redis . IDENT_12 . store . Override MOD_0 void METHOD_6 ( ) throws com . IDENT_10 . IDENT_11 . redis . IDENT_12 . store . Exception { try { while ( ! ( IDENT_6 . get ( ) ) ) { read . METHOD_7 ( ) ; long len = IDENT_14 . METHOD_15 ( ) ; if ( len != ( IDENT_2 . get ( ) ) ) { result . set ( false ) ; } write . METHOD_13 ( ) ; } } finally { IDENT_8 . METHOD_14 ( ) ; } } } ) ; IDENT_8 . METHOD_16 ( ) ; "<AssertPlaceHolder>" ; } get ( ) { METHOD_16 ( ) ; java . lang . Throwable IDENT_16 = METHOD_17 ( ) ; if ( METHOD_17 == null ) { return METHOD_18 ( ) ; } if ( METHOD_17 instanceof com . IDENT_10 . IDENT_11 . command . IDENT_17 ) { throw ( ( com . IDENT_10 . IDENT_11 . command . IDENT_17 ) ( METHOD_17 ) ) ; } throw new com . IDENT_10 . IDENT_11 . command . METHOD_19 ( METHOD_17 ) ; }
org . junit . Assert . assertTrue ( result . get ( ) )