Class DefaultTimer

api/src/main/java/org/apache/iceberg/metrics/DefaultTimer.java:35–120

A default Timer implementation that uses a Stopwatch instance internally to measure time.

 * measure time.
 */
public class DefaultTimer implements Timer {
  private final TimeUnit timeUnit;
  private final LongAdder count = new LongAdder();
  private final LongAdder totalTime = new LongAdder();

  public DefaultTimer(TimeUnit timeUnit) {
    Preconditions.checkArgument(null != timeUnit, "Invalid time unit: null");
    this.timeUnit = timeUnit;
  }

  @Override
  public long count() {
    return count.longValue();
  }

  @Override
  public Duration totalDuration() {
    return Duration.ofNanos(totalTime.longValue());
  }

  @Override
  public Timed start() {
    return new DefaultTimed(this, timeUnit);
  }

  @Override
  public void record(long amount, TimeUnit unit) {
    Preconditions.checkArgument(amount >= 0, "Cannot record %s %s: must be >= 0", amount, unit);
    this.totalTime.add(TimeUnit.NANOSECONDS.convert(amount, unit));
    this.count.increment();
  }

  @Override
  public <T> T time(Supplier<T> supplier) {
    try (Timed ignore = start()) {
      return supplier.get();
    }
  }

  @Override
  public <T> T timeCallable(Callable<T> callable) throws Exception {
    try (Timed ignore = start()) {
      return callable.call();
    }
  }

  @Override
  public void time(Runnable runnable) {
    try (Timed ignore = start()) {
      runnable.run();
    }
  }

  @Override
  public TimeUnit unit() {
    return timeUnit;
  }