src/org/objectweb/cjdbc/common/util/Stats.java

説明を見る。

package org.objectweb.cjdbc.common.util;

public class Stats
{
  private int    count;

  private int    error;

  private int    cacheHit;

  private long   minTime;

  private long   maxTime;

  private long   totalTime;

  private String name;

  public Stats(String statName)
  {
    name = statName;
    reset();
  }

  public synchronized void reset()
  {
    count = 0;
    error = 0;
    minTime = Long.MAX_VALUE;
    maxTime = Long.MIN_VALUE;
    totalTime = 0;
  }

  public synchronized void incrementCount()
  {
    count++;
  }

  public synchronized void incrementError()
  {
    error++;
  }

  public synchronized void incrementCacheHit()
  {
    cacheHit++;
  }

  public synchronized void updateTime(long time)
  {
    if (time < 0)
    {
      System.err.println("Negative time received in Stats.updateTime(" + time
          + ")\n");
      return;
    }
    totalTime += time;
    if (time > maxTime)
      maxTime = time;
    if (time < minTime)
      minTime = time;
  }

  public String getName()
  {
    return name;
  }

  public synchronized int getCount()
  {
    return count;
  }

  public synchronized int getError()
  {
    return error;
  }

  public synchronized int getCacheHit()
  {
    return cacheHit;
  }

  public synchronized long getMinTime()
  {
    return minTime;
  }

  public synchronized long getMaxTime()
  {
    return maxTime;
  }

  public synchronized long getTotalTime()
  {
    return totalTime;
  }

  public synchronized void merge(Stats anotherStat) throws Exception
  {
    if (this == anotherStat)
    {
      throw new Exception("You cannot merge a stat with itself");
    }

    count += anotherStat.getCount();
    error += anotherStat.getError();
    cacheHit += anotherStat.getCacheHit();
    if (minTime > anotherStat.getMinTime())
      minTime = anotherStat.getMinTime();
    if (maxTime < anotherStat.getMaxTime())
      maxTime = anotherStat.getMaxTime();
    totalTime += anotherStat.getTotalTime();
  }

  public void displayOnStdout()
  {
    System.out.println(multipleLineDisplay());
  }

  public String multipleLineDisplay()
  {
    String output = name + " statistics:\n" + "  Count: " + count + "\n"
        + "  Error: " + error + "\n";
    if (totalTime != 0)
    {
      output += "  Min time: " + minTime + " ms\n";
      output += "  Max time: " + maxTime + " ms\n";
    }
    else
    {
      output += "  Min time: 0 ms\n";
      output += "  Max time: 0 ms\n";
    }
    if (count == 0)
      output += "  Avg time: 0 ms\n";
    else
      output += "  Avg time: " + totalTime / count + " ms\n";
    output += "  Tot time: " + totalTime + " ms\n";

    double timeSec = totalTime / 1000;
    double timeMin = timeSec / 60, throup;
    throup = (timeMin != 0) ? (count / timeMin) : (count / timeSec);
    output += "  Throughput: " + throup
        + ((timeMin != 0) ? " requests/minute" : " requests/second");
    return output;
  }

  public String singleLineDisplay()
  {
    String output = name + " " + count + " " + error + " " + cacheHit + " ";
    if (count == 0)
      output += "0 ";
    else
      output += ((double) cacheHit / (double) count * 100.0) + " ";
    if (totalTime != 0)
      output += minTime + " " + maxTime + " ";
    else
      output += " 0 0 ";
    if (count == 0)
      output += "0 ";
    else
      output += totalTime / count + " ";
    output += totalTime;
    double timeSec = totalTime / 1000;
    double timeMin = timeSec / 60, throup;
    throup = (timeMin != 0) ? (count / timeMin) : (count / timeSec);
    output += throup
        + ((timeMin != 0) ? " requests/minute" : " requests/second");
    return output;
  }

  public String[] toStringTable()
  {
    String[] foo = {
        name,
        Integer.toString(count),
        Integer.toString(error),
        Integer.toString(cacheHit),
        (count == 0) ? "0" : Float.toString((float) cacheHit / (float) count
            * (float) 100.0), Long.toString(minTime), Long.toString(maxTime),
        (count == 0) ? "0" : Float.toString((float) totalTime / (float) count),
        Long.toString(totalTime)};
    return foo;
  }
}

---