Java 类com.google.common.util.concurrent.AbstractFutureBenchmarks.Facade 实例源码

项目：guava-mock 文件：SingleThreadAbstractFutureBenchmark.java

@Benchmark public long timeComplete_Failure(int reps) throws Exception {
  long r = 0;
  List<Facade<Integer>> list = new ArrayList<Facade<Integer>>(reps);
  for (int i = 0; i < reps; i++) {
    final Facade<Integer> localFuture = impl.newFacade();
    list.add(localFuture);
    localFuture.setException(exception);
  }
  for (int i = 0; i < reps; i++) {
    Facade<Integer> facade = list.get(i);
    try {
      facade.get();
      r++;
    } catch (ExecutionException e) {
      r += 2;
    }
  }
  return r;
}

项目：guava-mock 文件：SingleThreadAbstractFutureBenchmark.java

@Benchmark public long timeComplete_Cancel(int reps) throws Exception {
  long r = 0;
  List<Facade<Integer>> list = new ArrayList<Facade<Integer>>(reps);
  for (int i = 0; i < reps; i++) {
    final Facade<Integer> localFuture = impl.newFacade();
    list.add(localFuture);
    localFuture.cancel(false);
  }
  for (int i = 0; i < reps; i++) {
    Facade<Integer> facade = list.get(i);
    try {
      facade.get();
      r++;
    } catch (CancellationException e) {
      r += 2;
    }
  }
  return r;
}

项目：googles-monorepo-demo 文件：SingleThreadAbstractFutureBenchmark.java

@Benchmark public long timeComplete_Failure(int reps) throws Exception {
  long r = 0;
  List<Facade<Integer>> list = new ArrayList<Facade<Integer>>(reps);
  for (int i = 0; i < reps; i++) {
    final Facade<Integer> localFuture = impl.newFacade();
    list.add(localFuture);
    localFuture.setException(exception);
  }
  for (int i = 0; i < reps; i++) {
    Facade<Integer> facade = list.get(i);
    try {
      facade.get();
      r++;
    } catch (ExecutionException e) {
      r += 2;
    }
  }
  return r;
}

项目：googles-monorepo-demo 文件：SingleThreadAbstractFutureBenchmark.java

@Benchmark public long timeComplete_Cancel(int reps) throws Exception {
  long r = 0;
  List<Facade<Integer>> list = new ArrayList<Facade<Integer>>(reps);
  for (int i = 0; i < reps; i++) {
    final Facade<Integer> localFuture = impl.newFacade();
    list.add(localFuture);
    localFuture.cancel(false);
  }
  for (int i = 0; i < reps; i++) {
    Facade<Integer> facade = list.get(i);
    try {
      facade.get();
      r++;
    } catch (CancellationException e) {
      r += 2;
    }
  }
  return r;
}

项目：guava 文件：SingleThreadAbstractFutureBenchmark.java

@Benchmark
public long timeComplete_Failure(int reps) throws Exception {
  long r = 0;
  List<Facade<Integer>> list = new ArrayList<>(reps);
  for (int i = 0; i < reps; i++) {
    final Facade<Integer> localFuture = impl.newFacade();
    list.add(localFuture);
    localFuture.setException(exception);
  }
  for (int i = 0; i < reps; i++) {
    Facade<Integer> facade = list.get(i);
    try {
      facade.get();
      r++;
    } catch (ExecutionException e) {
      r += 2;
    }
  }
  return r;
}

项目：guava 文件：SingleThreadAbstractFutureBenchmark.java

@Benchmark
public long timeComplete_Cancel(int reps) throws Exception {
  long r = 0;
  List<Facade<Integer>> list = new ArrayList<>(reps);
  for (int i = 0; i < reps; i++) {
    final Facade<Integer> localFuture = impl.newFacade();
    list.add(localFuture);
    localFuture.cancel(false);
  }
  for (int i = 0; i < reps; i++) {
    Facade<Integer> facade = list.get(i);
    try {
      facade.get();
      r++;
    } catch (CancellationException e) {
      r += 2;
    }
  }
  return r;
}

项目：guava 文件：SingleThreadAbstractFutureBenchmark.java

@Benchmark
public long timeComplete_Failure(int reps) throws Exception {
  long r = 0;
  List<Facade<Integer>> list = new ArrayList<>(reps);
  for (int i = 0; i < reps; i++) {
    final Facade<Integer> localFuture = impl.newFacade();
    list.add(localFuture);
    localFuture.setException(exception);
  }
  for (int i = 0; i < reps; i++) {
    Facade<Integer> facade = list.get(i);
    try {
      facade.get();
      r++;
    } catch (ExecutionException e) {
      r += 2;
    }
  }
  return r;
}

项目：guava 文件：SingleThreadAbstractFutureBenchmark.java

@Benchmark
public long timeComplete_Cancel(int reps) throws Exception {
  long r = 0;
  List<Facade<Integer>> list = new ArrayList<>(reps);
  for (int i = 0; i < reps; i++) {
    final Facade<Integer> localFuture = impl.newFacade();
    list.add(localFuture);
    localFuture.cancel(false);
  }
  for (int i = 0; i < reps; i++) {
    Facade<Integer> facade = list.get(i);
    try {
      facade.get();
      r++;
    } catch (CancellationException e) {
      r += 2;
    }
  }
  return r;
}

项目：guava-mock 文件：SingleThreadAbstractFutureBenchmark.java

@Benchmark public long timeComplete_Normal(int reps) throws Exception {
  long r = 0;
  List<Facade<Integer>> list = new ArrayList<Facade<Integer>>(reps);
  for (int i = 0; i < reps; i++) {
    final Facade<Integer> localFuture = impl.newFacade();
    list.add(localFuture);
    localFuture.set(i);
  }
  for (int i = 0; i < reps; i++) {
    r += list.get(i).get();
  }
  return r;
}

项目：guava-mock 文件：SingleThreadAbstractFutureBenchmark.java

@Benchmark public long timeGetWith0Timeout(long reps) throws Exception {
  Facade<?> f = notDoneFuture;
  long r = 0;
  for (int i = 0; i < reps; i++) {
    try {
      f.get(0, TimeUnit.SECONDS);
      r += 1;
    } catch (TimeoutException e) {
      r += 2;
    }
  }
  return r;
}

项目：guava-mock 文件：SingleThreadAbstractFutureBenchmark.java

@Benchmark public long timeGetWithSmallTimeout(long reps) throws Exception {
  Facade<?> f = notDoneFuture;
  long r = 0;
  for (int i = 0; i < reps; i++) {
    try {
      f.get(500, TimeUnit.NANOSECONDS);
      r += 1;
    } catch (TimeoutException e) {
      r += 2;
    }
  }
  return r;
}

项目：googles-monorepo-demo 文件：SingleThreadAbstractFutureBenchmark.java

@Benchmark public long timeComplete_Normal(int reps) throws Exception {
  long r = 0;
  List<Facade<Integer>> list = new ArrayList<Facade<Integer>>(reps);
  for (int i = 0; i < reps; i++) {
    final Facade<Integer> localFuture = impl.newFacade();
    list.add(localFuture);
    localFuture.set(i);
  }
  for (int i = 0; i < reps; i++) {
    r += list.get(i).get();
  }
  return r;
}

项目：googles-monorepo-demo 文件：SingleThreadAbstractFutureBenchmark.java

@Benchmark public long timeGetWith0Timeout(long reps) throws Exception {
  Facade<?> f = notDoneFuture;
  long r = 0;
  for (int i = 0; i < reps; i++) {
    try {
      f.get(0, TimeUnit.SECONDS);
      r += 1;
    } catch (TimeoutException e) {
      r += 2;
    }
  }
  return r;
}

项目：googles-monorepo-demo 文件：SingleThreadAbstractFutureBenchmark.java

@Benchmark public long timeGetWithSmallTimeout(long reps) throws Exception {
  Facade<?> f = notDoneFuture;
  long r = 0;
  for (int i = 0; i < reps; i++) {
    try {
      f.get(500, TimeUnit.NANOSECONDS);
      r += 1;
    } catch (TimeoutException e) {
      r += 2;
    }
  }
  return r;
}

项目：guava 文件：SingleThreadAbstractFutureBenchmark.java

@Benchmark
public long timeComplete_Normal(int reps) throws Exception {
  long r = 0;
  List<Facade<Integer>> list = new ArrayList<>(reps);
  for (int i = 0; i < reps; i++) {
    final Facade<Integer> localFuture = impl.newFacade();
    list.add(localFuture);
    localFuture.set(i);
  }
  for (int i = 0; i < reps; i++) {
    r += list.get(i).get();
  }
  return r;
}

项目：guava 文件：SingleThreadAbstractFutureBenchmark.java

@Benchmark
public long timeGetWith0Timeout(long reps) throws Exception {
  Facade<?> f = notDoneFuture;
  long r = 0;
  for (int i = 0; i < reps; i++) {
    try {
      f.get(0, TimeUnit.SECONDS);
      r += 1;
    } catch (TimeoutException e) {
      r += 2;
    }
  }
  return r;
}

项目：guava 文件：SingleThreadAbstractFutureBenchmark.java

@Benchmark
public long timeGetWithSmallTimeout(long reps) throws Exception {
  Facade<?> f = notDoneFuture;
  long r = 0;
  for (int i = 0; i < reps; i++) {
    try {
      f.get(500, TimeUnit.NANOSECONDS);
      r += 1;
    } catch (TimeoutException e) {
      r += 2;
    }
  }
  return r;
}

项目：guava 文件：SingleThreadAbstractFutureBenchmark.java

@Benchmark
public long timeComplete_Normal(int reps) throws Exception {
  long r = 0;
  List<Facade<Integer>> list = new ArrayList<>(reps);
  for (int i = 0; i < reps; i++) {
    final Facade<Integer> localFuture = impl.newFacade();
    list.add(localFuture);
    localFuture.set(i);
  }
  for (int i = 0; i < reps; i++) {
    r += list.get(i).get();
  }
  return r;
}

项目：guava 文件：SingleThreadAbstractFutureBenchmark.java

@Benchmark
public long timeGetWith0Timeout(long reps) throws Exception {
  Facade<?> f = notDoneFuture;
  long r = 0;
  for (int i = 0; i < reps; i++) {
    try {
      f.get(0, TimeUnit.SECONDS);
      r += 1;
    } catch (TimeoutException e) {
      r += 2;
    }
  }
  return r;
}

项目：guava 文件：SingleThreadAbstractFutureBenchmark.java

@Benchmark
public long timeGetWithSmallTimeout(long reps) throws Exception {
  Facade<?> f = notDoneFuture;
  long r = 0;
  for (int i = 0; i < reps; i++) {
    try {
      f.get(500, TimeUnit.NANOSECONDS);
      r += 1;
    } catch (TimeoutException e) {
      r += 2;
    }
  }
  return r;
}