fetch flow for an execution . returns null , if execution not in queue concode_field_sep ConcurrentHashMap<Integer,Pair<ExecutionReference,ExecutableFlow>> queuedFlowMap concode_elem_sep Logger logger concode_elem_sep BlockingQueue<Pair<ExecutionReference,ExecutableFlow>> queuedFlowList concode_elem_sep long capacity concode_field_sep void enqueue concode_elem_sep void enqueueAll concode_elem_sep Pair<ExecutionReference,ExecutableFlow> fetchHead concode_elem_sep long size concode_elem_sep boolean hasExecution concode_elem_sep void dequeue concode_elem_sep Collection<Pair<ExecutionReference,ExecutableFlow>> getAllEntries concode_elem_sep boolean isEmpty concode_elem_sep void clear concode_elem_sep boolean isFull concode_elem_sep ExecutionReference getReference
ExecutableFlow function ( int arg0 ) { if ( hasExecution ( arg0 ) ) { return queuedFlowMap . get ( arg0 ) . getSecond ( ) ; } return null ; }