public void shutdown(){
  if (segmentsRemaining.get() > 0) {
    log.warn("Shutting down ReadManager while there are segments remaining.");
  }
 else {
    log.info("Shutting down record reader, no segments remaining.");
  }
  while (workers.size() > 0) {
    removeWorker(true);
  }
}

public void shutdown ( ) { if ( segmentsRemaining . get ( ) > 0 ) { log . warn ( "Shutting down ReadManager while there are segments remaining." ) ; } else { log . info ( "Shutting down record reader, no segments remaining." ) ; } while ( workers . size ( ) > 0 ) { removeWorker ( true ) ; } }
signal workers to stop work . note that this does not block and wait for them to complete . if they have pending work they may still push work to the multiplexer .
