in concurrency-loadbalancer-core/src/main/java/com/uber/concurrency/loadbalancer/timedcounter/WindowScheduledCounter.java [98:109]
private void tryPush() {
long n = lifespanTracker.purge() + expiredCount.getAndSet(0);
if (n == 0) {
return;
}
try {
consumer.accept(n);
} catch (Throwable t) {
expiredCount.addAndGet(n);
}
}