METHOD_0 ( ) { java . lang . StringBuilder sb = new java . lang . StringBuilder ( ) ; for ( int i = 0 ; i < 5 ; i ++ ) sb . append ( net . IDENT_0 . IDENT_1 . queue . impl . IDENT_2 . UUID . METHOD_1 ( ) ) ; java . lang . String text = sb . toString ( ) ; try ( net . IDENT_0 . IDENT_1 . queue . impl . IDENT_2 . IDENT_3 q = builder ( METHOD_2 ( ) , this . IDENT_4 ) . METHOD_3 ( net . IDENT_0 . IDENT_1 . queue . impl . IDENT_2 . IDENT_5 ) . build ( ) ) { System . err . println ( q . file ( ) ) ; final java . lang . IDENT_6 < net . IDENT_0 . IDENT_1 . queue . impl . IDENT_2 . IDENT_7 > IDENT_8 = java . lang . IDENT_6 . METHOD_4 ( q :: IDENT_9 ) ; int size = INT_0 ; int IDENT_10 = 8 ; int IDENT_11 = size / IDENT_10 ; net . IDENT_0 . IDENT_1 . queue . impl . IDENT_2 . IDENT_12 IDENT_13 = new net . IDENT_0 . IDENT_1 . queue . impl . IDENT_2 . METHOD_5 ( IDENT_10 ) ; for ( int j = 0 ; j < IDENT_10 ; j ++ ) { new java . lang . Thread ( ( ) -> { for ( int i = 0 ; i < IDENT_11 ; i ++ ) METHOD_6 ( IDENT_8 , text ) ; IDENT_13 . METHOD_7 ( ) ; } ) . start ( ) ; } IDENT_13 . METHOD_8 ( ) ; net . IDENT_0 . IDENT_1 . queue . impl . IDENT_2 . IDENT_14 IDENT_15 = q . METHOD_9 ( ) ; for ( int i = 0 ; i < size ; i ++ ) { try ( net . IDENT_0 . IDENT_1 . queue . impl . IDENT_2 . IDENT_16 dc = IDENT_15 . METHOD_10 ( false ) ) { long index = dc . index ( ) ; long actual = dc . METHOD_11 ( ) . read ( ( ) -> STRING_0 ) . METHOD_12 ( ) ; "<AssertPlaceHolder>" ; } } } } METHOD_13 ( net . IDENT_0 . IDENT_1 . queue . impl . IDENT_2 . IDENT_3 , long ) { return ( ( java . lang . Long . METHOD_14 ( q . METHOD_3 ( ) . METHOD_15 ( index ) ) ) + STRING_1 ) + ( java . lang . Long . METHOD_14 ( q . METHOD_3 ( ) . METHOD_16 ( index ) ) ) ; }
org . junit . Assert . assertEquals ( METHOD_13 ( q , index ) , METHOD_13 ( q , actual ) )