in kinesis-taxi-stream-producer/src/main/java/com/amazonaws/flink/refarch/utils/BackpressureSemaphore.java [42:50]
public void acquire(ListenableFuture<T> f) {
try {
semaphore.acquire();
Futures.addCallback(f, this);
} catch (InterruptedException e) {
semaphore.release();
}
}