METHOD_0 ( ) { final java . util . concurrent . IDENT_0 pool = java . util . concurrent . IDENT_1 . METHOD_1 ( ) ; final java . util . concurrent . atomic . IDENT_2 IDENT_3 = new java . util . concurrent . atomic . METHOD_2 ( 0 ) ; final java . util . concurrent . atomic . METHOD_2 IDENT_4 = new java . util . concurrent . atomic . METHOD_2 ( 0 ) ; final int IDENT_5 = 10 ; final int IDENT_6 = 10 ; final int IDENT_7 = 1000 ; final java . util . concurrent . IDENT_8 IDENT_9 = new java . util . concurrent . METHOD_3 ( ( ( IDENT_6 + IDENT_5 ) + 1 ) ) ; class IDENT_10 implements java . lang . IDENT_11 { @ uk . gov . IDENT_12 . IDENT_13 . resources . Override public void run ( ) { try { IDENT_9 . METHOD_4 ( ) ; java . util . function . IDENT_14 < java . lang . String > consumer = resource . METHOD_5 ( uk . gov . IDENT_12 . IDENT_13 . resources . IDENT_15 . IDENT_16 ) ; while ( ( IDENT_3 . METHOD_6 ( ) ) < IDENT_7 ) { consumer . accept ( uk . gov . IDENT_12 . IDENT_13 . resources . IDENT_15 . IDENT_17 ) ; } IDENT_9 . METHOD_4 ( ) ; } catch ( java . lang . Exception e ) { throw new java . lang . RuntimeException ( e ) ; } } } class IDENT_14 implements java . lang . IDENT_11 { @ uk . gov . IDENT_12 . IDENT_13 . resources . Override public void run ( ) { try { IDENT_9 . METHOD_4 ( ) ; java . util . function . IDENT_18 < java . lang . String > IDENT_19 = resource . METHOD_7 ( uk . gov . IDENT_12 . IDENT_13 . resources . IDENT_15 . IDENT_16 ) ; while ( ( IDENT_4 . METHOD_6 ( ) ) < IDENT_7 ) { IDENT_19 . get ( ) ; } IDENT_9 . METHOD_4 ( ) ; } catch ( java . lang . Exception e ) { throw new java . lang . RuntimeException ( e ) ; } } } try { java . util . stream . IDENT_20 . range ( 0 , IDENT_5 ) . METHOD_8 ( ( i ) -> pool . execute ( new uk . gov . IDENT_12 . IDENT_13 . resources . METHOD_9 ( ) ) ) ; java . util . stream . IDENT_20 . range ( 0 , IDENT_6 ) . METHOD_8 ( ( i ) -> pool . execute ( new java . util . function . METHOD_10 ( ) ) ) ; IDENT_9 . METHOD_4 ( ) ; IDENT_9 . METHOD_4 ( ) ; "<AssertPlaceHolder>" ; } catch ( java . lang . Exception e ) { throw new java . lang . RuntimeException ( e ) ; } } get ( ) { return java . util . stream . IDENT_21 . stream ( IDENT_22 . find ( ) . METHOD_11 ( ) , false ) . map ( ( document ) -> { try { return uk . gov . IDENT_12 . IDENT_13 . IDENT_23 . IDENT_24 . IDENT_25 . create ( document . getString ( IDENT_26 ) ) ; } catch ( e ) { return null ; } } ) . filter ( com . google . common . base . IDENT_27 . METHOD_12 ( ) ) ; }
org . junit . Assert . assertEquals ( IDENT_3 . get ( ) , IDENT_4 . get ( ) )