It is already using org.elasticsearch.common.util.concurrent.CountDown, no? Perhaps you read this as CountDownLatch. Admittedly my naming is confusing. Let me change the variable to 'countDown' rather than 'latch'.