void function ( ) { consumerExecutorService . shutdownNow ( ) ; }
shutdown the consumer executor service . concode_field_sep int SHUTDOWN_TIMEOUT_SECONDS concode_elem_sep AtomicInteger incrementer concode_elem_sep List<AggregatedSlidingWindowTimeReservoir> aggregatedTimeReservoirs concode_elem_sep double DELTA concode_elem_sep SlidingWindowTimeReservoir time10usReservoir concode_elem_sep ExecutorService producerExecutorService concode_elem_sep int PRODUCER_COUNT concode_elem_sep TimeUnit startUnitTime concode_elem_sep boolean doShutdown concode_elem_sep long startTime concode_elem_sep ExecutorService consumerExecutorService concode_elem_sep AggregatingTrimmer trimmer concode_elem_sep AggregatedSlidingWindowTimeReservoir time10DaysAggregatedReservoir concode_elem_sep Logger LOGGER concode_elem_sep AggregatedSlidingWindowTimeReservoir time1DayAggregatedReservoir concode_elem_sep int CONSUMER_COUNT concode_elem_sep int TEST_DURATION_MILLIS concode_field_sep void parallelProducersAndConsumersTestingAggregatedSlidingWindows concode_elem_sep void shutdownProducers concode_elem_sep long startTime concode_elem_sep void executeInParallel concode_elem_sep void checkInNanos