METHOD_0 ( ) { java . util . concurrent . atomic . IDENT_0 IDENT_1 = new java . util . concurrent . atomic . METHOD_1 ( true ) ; int IDENT_2 = 100 ; java . util . HashMap < java . lang . Integer , java . util . concurrent . IDENT_3 < java . lang . StringBuilder > > IDENT_4 = new java . util . HashMap ( ) ; java . lang . String IDENT_5 = this . getClass ( ) . getResource ( STRING_0 ) . METHOD_2 ( ) ; org . pentaho . di . job . IDENT_6 IDENT_7 = new org . pentaho . di . job . METHOD_3 ( IDENT_5 , null ) ; final org . pentaho . di . job . IDENT_8 job = new org . pentaho . di . job . METHOD_4 ( null , IDENT_7 ) ; java . util . concurrent . IDENT_9 IDENT_10 = java . util . concurrent . IDENT_11 . METHOD_5 ( IDENT_2 ) ; for ( int i = 0 ; i < IDENT_2 ; i ++ ) { java . util . concurrent . IDENT_3 < java . lang . StringBuilder > future = IDENT_10 . METHOD_6 ( new java . util . concurrent . IDENT_12 < java . lang . StringBuilder > ( ) { MOD_0 org . pentaho . di . job . StringBuilder IDENT_13 = new java . lang . StringBuilder ( ) ; @ org . pentaho . di . job . Override public org . pentaho . di . job . StringBuilder call ( ) throws org . pentaho . di . job . Exception { while ( IDENT_1 . get ( ) ) { IDENT_13 . append ( job . getStatus ( ) ) ; java . lang . Thread . sleep ( 10 ) ; } return IDENT_13 ; } } ) ; IDENT_4 . put ( i , future ) ; } job . start ( ) ; job . METHOD_7 ( ) ; IDENT_1 . set ( false ) ; for ( java . util . concurrent . IDENT_3 < java . lang . StringBuilder > IDENT_14 : IDENT_4 . values ( ) ) { "<AssertPlaceHolder>" ; } IDENT_10 . METHOD_8 ( ) ; } METHOD_9 ( java . lang . String ) { java . lang . String [ ] tokens = new java . lang . String [ ] { STRING_1 , STRING_2 , STRING_3 } ; int offset = 0 ; for ( java . lang . String t : tokens ) { while ( status . startsWith ( t , offset ) ) offset += t . length ( ) ; } return offset == ( status . length ( ) ) ; }
org . junit . Assert . assertTrue ( METHOD_9 ( IDENT_14 . get ( ) . toString ( ) ) )