public void flush(){
synchronized (list) {
    int n=0;
    long m=0L;
    for (    T b : list) {
      if (halt)       throw new RuntimeException(firstCause.get());
      final int size=b.size();
      final long counter=b.flush();
      m+=counter;
      if (DEBUG)       log.debug("Flushed buffer: size=" + size + ", counter="+ counter);
    }
    if (INFO)     log.info("Flushed " + n + " unsynchronized buffers totalling "+ m+ " elements");
  }
}

public void flush ( ) { synchronized ( list ) { int n = 0 ; long m = 0L ; for ( T b : list ) { if ( halt ) throw new RuntimeException ( firstCause . get ( ) ) ; final int size = b . size ( ) ; final long counter = b . flush ( ) ; m += counter ; if ( DEBUG ) log . debug ( "Flushed buffer: size=" + size + ", counter=" + counter ) ; } if ( INFO ) log . info ( "Flushed " + n + " unsynchronized buffers totalling " + m + " elements" ) ; } }
flush each of the unsynchronized buffers onto their backing synchronized buffer .
