import com.google.caliper.model.ArbitraryMeasurement; //导入依赖的package包/类
@ArbitraryMeasurement(description = "requests per second")
public double run() throws Exception {
  if (VERBOSE) System.out.println(toString());
  HttpClient httpClient = client.create();

  // Prepare the client & server
  httpClient.prepare(this);
  MockWebServer server = startServer();
  HttpUrl url = server.url("/");

  int requestCount = 0;
  long reportStart = System.nanoTime();
  long reportPeriod = TimeUnit.SECONDS.toNanos(1);
  int reports = 0;
  double best = 0.0;

  // Run until we've printed enough reports.
  while (reports < NUM_REPORTS) {
    // Print a report if we haven't recently.
    long now = System.nanoTime();
    double reportDuration = now - reportStart;
    if (reportDuration > reportPeriod) {
      double requestsPerSecond = requestCount / reportDuration * TimeUnit.SECONDS.toNanos(1);
      if (VERBOSE) {
        System.out.println(String.format("Requests per second: %.1f", requestsPerSecond));
      }
      best = Math.max(best, requestsPerSecond);
      requestCount = 0;
      reportStart = now;
      reports++;
    }

    // Fill the job queue with work.
    while (httpClient.acceptingJobs()) {
      httpClient.enqueue(url);
      requestCount++;
    }

    // The job queue is full. Take a break.
    sleep(1);
  }

  return best;
}
 

import com.google.caliper.model.ArbitraryMeasurement; //导入依赖的package包/类
@ArbitraryMeasurement(description = "requests per second")
public double run() throws Exception {
  if (VERBOSE) System.out.println(toString());
  HttpClient httpClient = client.create();

  // Prepare the client & server
  httpClient.prepare(this);
  MockWebServer server = startServer();
  URL url = server.getUrl("/");

  int requestCount = 0;
  long reportStart = System.nanoTime();
  long reportPeriod = TimeUnit.SECONDS.toNanos(1);
  int reports = 0;
  double best = 0.0;

  // Run until we've printed enough reports.
  while (reports < NUM_REPORTS) {
    // Print a report if we haven't recently.
    long now = System.nanoTime();
    double reportDuration = now - reportStart;
    if (reportDuration > reportPeriod) {
      double requestsPerSecond = requestCount / reportDuration * TimeUnit.SECONDS.toNanos(1);
      if (VERBOSE) {
        System.out.println(String.format("Requests per second: %.1f", requestsPerSecond));
      }
      best = Math.max(best, requestsPerSecond);
      requestCount = 0;
      reportStart = now;
      reports++;
    }

    // Fill the job queue with work.
    while (httpClient.acceptingJobs()) {
      httpClient.enqueue(url);
      requestCount++;
    }

    // The job queue is full. Take a break.
    sleep(1);
  }

  return best;
}
 

import com.google.caliper.model.ArbitraryMeasurement; //导入依赖的package包/类
@ArbitraryMeasurement
public double arbitraryBenchmark() {
  return doBenchmark();
}
 

import com.google.caliper.model.ArbitraryMeasurement; //导入依赖的package包/类
@ArbitraryMeasurement
public double arbitraryBenchmark() {
  return arbitaryPiBenchmark();
}