in concurrency-loadbalancer-core/src/main/java/com/uber/concurrency/loadbalancer/AbstractConcurrencyLoadBalancer.java [203:210]
void markSelection(T task) {
Meter taskMeter = taskRequestRate.get(task);
if (taskMeter == null) {
return;
}
requestRate.mark();
taskMeter.mark();
}