protected void waitForComponentsToInitialize() {
...
LOGGER.debug("Waiting for {} Data Generators to be ready.", taskGenContainerIds.size());
try {
taskGenReadyMutex.acquire(taskGenContainerIds.size());
} catch (InterruptedException e) {
String errorMsg = "Interrupted while waiting for the task generators to be ready.";
LOGGER.error(errorMsg);
throw new IllegalStateException(errorMsg, e);
}
......
}