V function ( String arg0 ) { try { V loc0 = retrieveSharedQueue ( arg0 ) . take ( ) ; mediations . remove ( arg0 ) ; return loc0 ; } catch ( InterruptedException loc0 ) { throw new RuntimeException ( loc0 ) ; } }
blocking retrieval and removal of the object to share concode_field_sep ConcurrentMap<String,BlockingQueue<V>> mediations concode_field_sep void handIn concode_elem_sep V get concode_elem_sep BlockingQueue<V> retrieveSharedQueue concode_elem_sep void remove