From 926b17364fb1588063c0b24e2bfaeb1ccb208f3c Mon Sep 17 00:00:00 2001 From: bd2019us Date: Sun, 31 Mar 2019 21:34:12 -0500 Subject: [PATCH 1/2] change cached thread pool to fixed thread pool --- .../java/org/apache/bookkeeper/tools/perf/table/PerfClient.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/tools/perf/src/main/java/org/apache/bookkeeper/tools/perf/table/PerfClient.java b/tools/perf/src/main/java/org/apache/bookkeeper/tools/perf/table/PerfClient.java index 4b3442700cf..8530c7319ef 100644 --- a/tools/perf/src/main/java/org/apache/bookkeeper/tools/perf/table/PerfClient.java +++ b/tools/perf/src/main/java/org/apache/bookkeeper/tools/perf/table/PerfClient.java @@ -324,7 +324,7 @@ private void runBenchmarkTasks() throws Exception { final CountDownLatch latch = new CountDownLatch(tasks.size()); @Cleanup("shutdown") - ExecutorService executor = Executors.newCachedThreadPool(); + ExecutorService executor = Executors.newFixedThreadPool(task.size()); for (BenchmarkTask task : tasks) { executor.submit(() -> { try { From 8480541673d7aec982d12c4f2ed7e4efcdd07ae5 Mon Sep 17 00:00:00 2001 From: bd2019us Date: Tue, 2 Apr 2019 09:52:26 -0500 Subject: [PATCH 2/2] fix compilation error --- .../java/org/apache/bookkeeper/tools/perf/table/PerfClient.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/tools/perf/src/main/java/org/apache/bookkeeper/tools/perf/table/PerfClient.java b/tools/perf/src/main/java/org/apache/bookkeeper/tools/perf/table/PerfClient.java index 8530c7319ef..835f816c655 100644 --- a/tools/perf/src/main/java/org/apache/bookkeeper/tools/perf/table/PerfClient.java +++ b/tools/perf/src/main/java/org/apache/bookkeeper/tools/perf/table/PerfClient.java @@ -324,7 +324,7 @@ private void runBenchmarkTasks() throws Exception { final CountDownLatch latch = new CountDownLatch(tasks.size()); @Cleanup("shutdown") - ExecutorService executor = Executors.newFixedThreadPool(task.size()); + ExecutorService executor = Executors.newFixedThreadPool(tasks.size()); for (BenchmarkTask task : tasks) { executor.submit(() -> { try {