//
// ========================================================================
// Copyright (c) 1995-2019 Mort Bay Consulting Pty. Ltd.
// ------------------------------------------------------------------------
// All rights reserved. This program and the accompanying materials
// are made available under the terms of the Eclipse Public License v1.0
// and Apache License v2.0 which accompanies this distribution.
//
// The Eclipse Public License is available at
// http://www.eclipse.org/legal/epl-v10.html
//
// The Apache License v2.0 is available at
// http://www.opensource.org/licenses/apache2.0.php
//
// You may elect to redistribute this code under either of these licenses.
// ========================================================================
//
package org.eclipse.jetty.util.statistic;
import java.util.concurrent.atomic.AtomicLong;
import java.util.concurrent.atomic.LongAccumulator;
import java.util.concurrent.atomic.LongAdder;
Statistics on a counter value.
This class keeps the total, current and maximum value of a counter
that can be incremented and decremented. The total refers only to increments.
/**
* <p>Statistics on a counter value.</p>
* <p>This class keeps the total, current and maximum value of a counter
* that can be incremented and decremented. The total refers only to increments.</p>
*/
public class CounterStatistic
{
private final LongAccumulator _max = new LongAccumulator(Math::max, 0L);
private final AtomicLong _current = new AtomicLong();
private final LongAdder _total = new LongAdder();
Resets the max and total to the current value.
/**
* Resets the max and total to the current value.
*/
public void reset()
{
_total.reset();
_max.reset();
long current = _current.get();
_total.add(current);
_max.accumulate(current);
}
Resets the max, total and current value to the given parameter.
Params: - value – the new current value
/**
* Resets the max, total and current value to the given parameter.
*
* @param value the new current value
*/
public void reset(final long value)
{
_current.set(value);
_total.reset();
_max.reset();
if (value > 0)
{
_total.add(value);
_max.accumulate(value);
}
}
Params: - delta – the amount to add to the counter
Returns: the new counter value
/**
* @param delta the amount to add to the counter
* @return the new counter value
*/
public long add(final long delta)
{
long value = _current.addAndGet(delta);
if (delta > 0)
{
_total.add(delta);
_max.accumulate(value);
}
return value;
}
Increments the value by one.
Returns: the new counter value after the increment
/**
* Increments the value by one.
*
* @return the new counter value after the increment
*/
public long increment()
{
long value = _current.incrementAndGet();
_total.increment();
_max.accumulate(value);
return value;
}
Decrements the value by one.
Returns: the new counter value after the decrement
/**
* Decrements the value by one.
*
* @return the new counter value after the decrement
*/
public long decrement()
{
return _current.decrementAndGet();
}
Returns: max counter value
/**
* @return max counter value
*/
public long getMax()
{
return _max.get();
}
Returns: current counter value
/**
* @return current counter value
*/
public long getCurrent()
{
return _current.get();
}
Returns: total counter value
/**
* @return total counter value
*/
public long getTotal()
{
return _total.sum();
}
@Override
public String toString()
{
return String.format("%s@%x{c=%d,m=%d,t=%d}", getClass().getSimpleName(), hashCode(), getCurrent(), getMax(), getTotal());
}
}