Fix thread pool creation

acogoluegnes · acogoluegnes · commit ee984b2f4c98 · 2018-01-22T10:41:46.000+01:00
[#154174064] References #70
diff --git a/src/main/java/com/rabbitmq/perf/MulticastSet.java b/src/main/java/com/rabbitmq/perf/MulticastSet.java
@@ -220,10 +220,7 @@ public ExecutorService executorService(String name, int nbThreads) {
             if (nbThreads <= 0) {
                 return create(() -> Executors.newSingleThreadExecutor(new NamedThreadFactory(name)));
             } else {
-                return create(() -> new ThreadPoolExecutor(nbThreads, nbThreads,
-                    60L, TimeUnit.SECONDS,
-                    new SynchronousQueue<>(),
-                    new NamedThreadFactory(name)));
+                return create(() -> Executors.newFixedThreadPool(nbThreads, new NamedThreadFactory(name)));
             }
         }
 

Original file line number	Diff line number	Diff line change
`@@ -220,10 +220,7 @@ public ExecutorService executorService(String name, int nbThreads) {`
`220`	`220`	`if (nbThreads <= 0) {`
`221`	`221`	`return create(() -> Executors.newSingleThreadExecutor(new NamedThreadFactory(name)));`
`222`	`222`	`} else {`
`223`		`- return create(() -> new ThreadPoolExecutor(nbThreads, nbThreads,`
`224`		`- 60L, TimeUnit.SECONDS,`
`225`		`- new SynchronousQueue<>(),`
`226`		`- new NamedThreadFactory(name)));`
	`223`	`+ return create(() -> Executors.newFixedThreadPool(nbThreads, new NamedThreadFactory(name)));`
`227`	`224`	`}`
`228`	`225`	`}`
`229`	`226`