class BackPressureRequestCoordinator {

	public void shutDown() {
		synchronized (lock) {
			if (!isShutDown) {
				LOG.info("Shutting down back pressure request coordinator.");

				for (PendingBackPressureRequest pending : pendingRequests.values()) {
					pending.discard(new RuntimeException("Shut down."));
				}

				pendingRequests.clear();
				recentPendingRequests.clear();

				isShutDown = true;
			}
		}
	}

	public  BackPressureRequestCoordinator(
			Executor executor,
			long requestTimeout);

}