void function ( ) { queue . offer ( buffer ) ; }
called by iteration tail to signal that all input of a superstep has been processed unblocks iteration head . concode_field_sep SerializedUpdateBuffer buffer concode_elem_sep BlockingQueue<SerializedUpdateBuffer> queue concode_field_sep DataInputView getReadEndAfterSuperstepEnded concode_elem_sep DataOutputView getWriteEnd