in concurrency-loadbalancer-core/src/main/java/com/uber/concurrency/loadbalancer/utils/HashIndexedPriorityQueue.java [149:156]
protected void validate() {
for (Map.Entry<E,Integer> entry: entityToIndex.entrySet()) {
int index = entry.getValue();
if (entityList.get(index) != entry.getKey()) {
throw new IllegalStateException("entity " + entry + " is not at expected index " + index);
}
}
}