From 0db4061af182a09117ca2d3e289558486d386cb6 Mon Sep 17 00:00:00 2001 From: Andrew Carbonetto Date: Fri, 24 Nov 2023 13:48:31 -0800 Subject: [PATCH] Supply an Executor Signed-off-by: Andrew Carbonetto --- .../java/javababushka/benchmarks/utils/Benchmarking.java | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/java/benchmarks/src/main/java/javababushka/benchmarks/utils/Benchmarking.java b/java/benchmarks/src/main/java/javababushka/benchmarks/utils/Benchmarking.java index 4c831cafbc..b086da6e95 100644 --- a/java/benchmarks/src/main/java/javababushka/benchmarks/utils/Benchmarking.java +++ b/java/benchmarks/src/main/java/javababushka/benchmarks/utils/Benchmarking.java @@ -8,6 +8,8 @@ import java.util.Map; import java.util.concurrent.CompletableFuture; import java.util.concurrent.ExecutionException; +import java.util.concurrent.ExecutorService; +import java.util.concurrent.Executors; import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeoutException; import java.util.concurrent.atomic.AtomicInteger; @@ -152,6 +154,8 @@ public static void printResults( public static void testClientSetGet( Supplier clientCreator, BenchmarkingApp.RunConfiguration config, boolean async) { + ExecutorService asyncExecutor = Executors.newFixedThreadPool( + Runtime.getRuntime().availableProcessors() + 1); for (int concurrentNum : config.concurrentTasks) { int iterations = Math.min(Math.max(100000, concurrentNum * 10000), 10000000); for (int clientCount : config.clientCount) { @@ -212,7 +216,7 @@ public static void testClientSetGet( clientIndex = iterationIncrement % clients.size(); } return taskActionResults; - })); + }, asyncExecutor)); } if (config.debugLogging) { System.out.printf("%s client Benchmarking: %n", clientName);