METHOD_0 ( ) { final java . util . concurrent . IDENT_0 < org . apache . druid . client . cache . IDENT_1 . IDENT_2 > q = org . apache . druid . client . cache . IDENT_1 . METHOD_1 ( Integer . MAX_VALUE ) ; long IDENT_3 = TimeUnit . IDENT_4 . METHOD_2 ( 10 ) ; java . util . concurrent . IDENT_5 executor = java . util . concurrent . IDENT_6 . METHOD_3 ( ) ; final java . util . concurrent . atomic . IDENT_7 IDENT_8 = new java . util . concurrent . atomic . METHOD_4 ( false ) ; java . util . List < java . util . concurrent . IDENT_9 > IDENT_10 = new java . util . ArrayList ( ) ; for ( int i = 0 ; i < 5 ; i ++ ) { IDENT_10 . add ( executor . METHOD_5 ( new java . util . concurrent . IDENT_11 < java . lang . Boolean > ( ) { @ org . apache . druid . client . cache . Override public org . apache . druid . client . cache . Boolean call ( ) { while ( ! ( IDENT_8 . get ( ) ) ) { q . add ( new org . apache . druid . client . cache . IDENT_1 . METHOD_6 ( 1 ) ) ; q . add ( new org . apache . druid . client . cache . IDENT_1 . METHOD_6 ( 2 ) ) ; } return true ; } } ) ) ; } for ( int i = 0 ; i < 10 ; i ++ ) { IDENT_10 . add ( executor . METHOD_5 ( new java . util . concurrent . IDENT_11 < java . lang . Boolean > ( ) { @ org . apache . druid . client . cache . Override public org . apache . druid . client . cache . Boolean call ( ) throws org . apache . druid . client . cache . IDENT_12 { while ( ! ( IDENT_8 . get ( ) ) ) { q . METHOD_7 ( 100 , TimeUnit . IDENT_13 ) ; q . METHOD_8 ( new org . apache . druid . client . cache . IDENT_1 . METHOD_6 ( 2 ) ) ; } return true ; } } ) ) ; } for ( int i = 0 ; i < 5 ; i ++ ) { IDENT_10 . add ( executor . METHOD_5 ( new java . util . concurrent . IDENT_11 < java . lang . Boolean > ( ) { @ org . apache . druid . client . cache . Override public org . apache . druid . client . cache . Boolean call ( ) { while ( ! ( IDENT_8 . get ( ) ) ) { q . METHOD_9 ( new java . util . ArrayList ( ) , Integer . MAX_VALUE ) ; } return true ; } } ) ) ; } java . lang . Thread . sleep ( IDENT_3 ) ; IDENT_8 . set ( true ) ; for ( java . util . concurrent . IDENT_9 < java . lang . Boolean > future : IDENT_10 ) { "<AssertPlaceHolder>" ; } } get ( ) { if ( root . METHOD_10 ( ) ) { return IDENT_14 . METHOD_11 ( ) ; } else { return org . apache . druid . java . util . common . IDENT_15 . IDENT_16 . map ( IDENT_14 . METHOD_11 ( ) , new com . google . common . base . IDENT_17 < java . lang . Object [ ] , java . lang . Object [ ] > ( ) { @ org . apache . druid . sql . calcite . IDENT_18 . Override public java . lang . Object [ ] apply ( final java . lang . Object [ ] input ) { final java . lang . Object [ ] IDENT_19 = new java . lang . Object [ root . fields . size ( ) ] ; for ( int i = 0 ; i < ( root . fields . size ( ) ) ; i ++ ) { IDENT_19 [ i ] = input [ root . fields . get ( i ) . getKey ( ) ] ; } return IDENT_19 ; } } ) ; } }
org . junit . Assert . assertTrue ( future . get ( ) )