void function ( Workload arg0 ) { try { Future loc0 = jobs . get ( arg0 ) ; loc0 . get ( ) ; jobs . remove ( arg0 ) ; } catch ( InterruptedException | ExecutionException loc0 ) { logger . error ( "srini_string" , loc0 ) ; } }
calls the java.util.concurrent.future #get method pertaining to this workflow.once the future competes , the workflow is removed from the list . concode_field_sep Map<Workload,Future> jobs concode_elem_sep Logger logger concode_elem_sep int poolSize concode_elem_sep ExecutorService pool concode_field_sep void add concode_elem_sep void init concode_elem_sep ExecutorService getPool concode_elem_sep void complete concode_elem_sep void shutdown