processes a parameter as if it was in the queue , without ever passing to another thread . concode_field_sep int FINISHED concode_elem_sep int state concode_elem_sep ThreadPoolExecutor pool concode_elem_sep int STAGE_1_ASYNC concode_elem_sep int STAGE_1_SYNC concode_elem_sep AtomicIntegerFieldUpdater STATE_FIELD concode_elem_sep int PENDING concode_elem_sep E t concode_elem_sep Queue<Task> finished concode_elem_sep CallBackProvider<P,T,C,E> provider concode_elem_sep Map<P,Task> tasks concode_elem_sep P parameter concode_elem_sep List<C> callbacks concode_elem_sep int STAGE_1_COMPLETE concode_elem_sep T object concode_field_sep boolean drop concode_elem_sep boolean drop concode_elem_sep void add concode_elem_sep void init concode_elem_sep void finishActive concode_elem_sep boolean set concode_elem_sep T skipQueue concode_elem_sep void run concode_elem_sep void setActiveThreads concode_elem_sep boolean initAsync concode_elem_sep void callStage3 concode_elem_sep void initSync concode_elem_sep void callStage2 concode_elem_sep T callStage1 concode_elem_sep T get concode_elem_sep T get concode_elem_sep void finish
T function ( P arg0 , C ... arg1 ) { final CallBackProvider < P , T , C , E > loc0 = this . provider ; final T loc1 = skipQueue ( arg0 ) ; for ( C loc2 : arg1 ) { loc0 . callStage3 ( arg0 , loc1 , loc2 ) ; } return loc1 ; }