andreacavalli/netty5
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Correctly construct Executor in microbenchmarks.

Browse Source 
Motivation:

We should allow our custom Executor to shutdown quickly.

Modifications:

Call super constructor which correct arguments.

Result:

Custom Executor can be shutdown quickly.
This commit is contained in:
Norman Maurer 2015-11-03 09:40:16 +01:00
parent a60c472fa4
commit efeec7e390
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
microbench/src/test/java/io/netty/microbench/util/AbstractMicrobenchmark.java
View File

@ -30,7 +30,7 @@ import org.openjdk.jmh.runner.options.ChainedOptionsBuilder;
import org.openjdk.jmh.runner.options.OptionsBuilder; import org.openjdk.jmh.runner.options.OptionsBuilder;
import java.io.File; import java.io.File;
import java.util.concurrent.SynchronousQueue; import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor; import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeUnit;
@ -49,8 +49,8 @@ public class AbstractMicrobenchmark {
public static final class HarnessExecutor extends ThreadPoolExecutor { public static final class HarnessExecutor extends ThreadPoolExecutor {
public HarnessExecutor(int maxThreads, String prefix) { public HarnessExecutor(int maxThreads, String prefix) {
super(0, maxThreads, 1L, TimeUnit.DAYS, new SynchronousQueue<Runnable>(), super(maxThreads, maxThreads, 0, TimeUnit.MILLISECONDS,
new DefaultThreadFactory(prefix)); new LinkedBlockingQueue<Runnable>(), new DefaultThreadFactory(prefix));
System.out.println("Using harness executor"); System.out.println("Using harness executor");
} }
} }