BlockingBenchmark.java

/*
 * BlockingBenchmark.java
 *
 * This source file is part of the FoundationDB open source project
 *
 * Copyright 2013-2018 Apple Inc. and the FoundationDB project authors
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

package com.apple.foundationdb.test;

import java.util.ArrayList;
import java.util.concurrent.CompletableFuture;
import java.util.function.Function;

import com.apple.foundationdb.Database;
import com.apple.foundationdb.FDB;
import com.apple.foundationdb.Transaction;

public class BlockingBenchmark {
	private static final int REPS = 100000;
	private static final int PARALLEL = 100;

	public static void main(String[] args) throws InterruptedException {
		FDB fdb = FDB.selectAPIVersion(700);

		// The cluster file DOES NOT need to be valid, although it must exist.
		//  This is because the database is never really contacted in this test.
		try(Database database = fdb.open()) {
			try(Transaction tr = database.createTransaction()) {
				tr.setReadVersion(100000);

				System.out.println("readVersion().join():");
				runTests(tr, o -> {
					try {
						o.join();
					}
					catch(Exception e) {
						// Ignore
					}
					return null;
				});

				System.out.println("readVersion().get():");
				runTests(tr, o -> {
					try {
						o.get();
					}
					catch(Exception e) {
						// Ignore
					}
					return null;
				});

				System.out.println("readVersion().thenApplyAsync(identity).get():");
				runTests(tr, o -> {
					try {
						o.thenApplyAsync(Function.identity(), FDB.DEFAULT_EXECUTOR).get();
					}
					catch(Exception e) {
						// Ignore
					}
					return null;
				});

				System.out.println("readVersion().thenApplyAsync^10(identity).get():");
				runTests(tr, o -> {
					for(int i = 0; i < 10; i++)
						o = o.thenApplyAsync(Function.identity(), FDB.DEFAULT_EXECUTOR);
					try {
						o.get();
					}
					catch(Exception e) {
						// Ignore
					}
					return null;
				});

				System.out.println("readVersion().get^100():");
				runTests(tr, o -> {
					for(int i = 0; i < 100; i++) {
						try {
							o.get();
						}
						catch(Exception e) {
							// Ignore
						}
					}
					return null;
				});
			}
		}
	}

	private static void runTests(Transaction tr, Function<CompletableFuture<Long>, Void> blockMethod) {
		for(int r=0; r<4; r++) {
			long start = System.currentTimeMillis();
			for(int i = 0; i < REPS; i++) {
				blockMethod.apply(tr.getReadVersion());
			}

			long taken = System.currentTimeMillis() - start;
			System.out.println("  " + REPS + " done in " + taken + "ms -> " + ((taken * 1000.0) / REPS) + " us latency");

			ArrayList<CompletableFuture<Long>> futures = new ArrayList<CompletableFuture<Long>>(PARALLEL);
			for(int j=0; j<PARALLEL; j++)
				futures.add(null);

			start = System.currentTimeMillis();
			for(int i = 0; i < REPS; i += PARALLEL) {
				for(int j=0; j<PARALLEL; j++)
					futures.set(j, tr.getReadVersion());
				for(int j=0; j<PARALLEL; j++)
					blockMethod.apply(futures.get(j));
			}
			taken = System.currentTimeMillis() - start;
			System.out.println("  " + REPS + " done in " + taken + "ms -> " + (REPS / (taken)) + " KHz");
		}
	}

	private BlockingBenchmark() {}
}