in concurrency-loadbalancer-core/src/main/java/com/uber/concurrency/loadbalancer/utils/HashIndexedPriorityQueue.java [63:74]
public HashIndexedPriorityQueue(Comparator<E> comparator) {
this.entityToIndex = new HashMap<>();
this.entityList = new ArrayList<>();
if (comparator == null) {
this.comparator = (o1, o2) -> {
Comparable<E> c1 = (Comparable)o1;
return c1.compareTo(o2);
};
} else {
this.comparator = comparator;
}
}