private void tryPush()

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);
        }
    }