grpc
/
grpc-java
mirror of https://github.com/grpc/grpc-java.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

benchmarks: daemonize threads to reduce the number of stacktraces

This commit is contained in:
Carl Mastrangelo 2016-07-18 11:37:37 -07:00
parent 297af4425e
commit fa86c8eb74
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
benchmarks/src/jmh/java/io/grpc/benchmarks/netty/AbstractBenchmark.java
View File

@ -55,6 +55,7 @@ import io.netty.channel.local.LocalAddress;
import io.netty.channel.local.LocalChannel; import io.netty.channel.local.LocalChannel;
import io.netty.channel.local.LocalServerChannel; import io.netty.channel.local.LocalServerChannel;
import io.netty.channel.nio.NioEventLoopGroup; import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.util.concurrent.DefaultThreadFactory;
import java.net.InetAddress; import java.net.InetAddress;
import java.net.InetSocketAddress; import java.net.InetSocketAddress;
@ -64,6 +65,7 @@ import java.net.SocketAddress;
import java.net.SocketException; import java.net.SocketException;
import java.net.UnknownHostException; import java.net.UnknownHostException;
import java.util.Enumeration; import java.util.Enumeration;
import java.util.concurrent.ThreadFactory;
import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicBoolean; import java.util.concurrent.atomic.AtomicBoolean;
import java.util.concurrent.atomic.AtomicLong; import java.util.concurrent.atomic.AtomicLong;
@ -227,7 +229,8 @@ public abstract class AbstractBenchmark {
} }
// Always use a different worker group from the client. // Always use a different worker group from the client.
serverBuilder.workerEventLoopGroup(new NioEventLoopGroup()); ThreadFactory serverThreadFactory = new DefaultThreadFactory("STF pool", true /* daemon */);
serverBuilder.workerEventLoopGroup(new NioEventLoopGroup(0, serverThreadFactory));
// Always set connection and stream window size to same value // Always set connection and stream window size to same value
serverBuilder.flowControlWindow(windowSize.bytes()); serverBuilder.flowControlWindow(windowSize.bytes());
@ -376,10 +379,11 @@ public abstract class AbstractBenchmark {
server = serverBuilder.build(); server = serverBuilder.build();
server.start(); server.start();
channels = new ManagedChannel[channelCount]; channels = new ManagedChannel[channelCount];
ThreadFactory clientThreadFactory = new DefaultThreadFactory("CTF pool", true /* daemon */);
for (int i = 0; i < channelCount; i++) { for (int i = 0; i < channelCount; i++) {
// Use a dedicated event-loop for each channel // Use a dedicated event-loop for each channel
channels[i] = channelBuilder channels[i] = channelBuilder
.eventLoopGroup(new NioEventLoopGroup(1)) .eventLoopGroup(new NioEventLoopGroup(1, clientThreadFactory))
.build(); .build();
} }
} }