HBASE-16614 Use daemon thread for netty event loop
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/0860bdb6 Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/0860bdb6 Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/0860bdb6 Branch: refs/heads/hbase-12439 Commit: 0860bdb675180a7ed9a1bbafe542b9e730d39e31 Parents: 105bfc7 Author: zhangduo <zhang...@apache.org> Authored: Mon Sep 12 16:32:03 2016 +0800 Committer: zhangduo <zhang...@apache.org> Committed: Mon Sep 12 22:05:03 2016 +0800 ---------------------------------------------------------------------- .../apache/hadoop/hbase/ipc/DefaultNettyEventLoopConfig.java | 5 ++++- .../main/java/org/apache/hadoop/hbase/ipc/NettyRpcClient.java | 4 +++- 2 files changed, 7 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hbase/blob/0860bdb6/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/DefaultNettyEventLoopConfig.java ---------------------------------------------------------------------- diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/DefaultNettyEventLoopConfig.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/DefaultNettyEventLoopConfig.java index c7c0f32..f710d54 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/DefaultNettyEventLoopConfig.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/DefaultNettyEventLoopConfig.java @@ -21,6 +21,7 @@ import io.netty.channel.Channel; import io.netty.channel.EventLoopGroup; import io.netty.channel.nio.NioEventLoopGroup; import io.netty.channel.socket.nio.NioSocketChannel; +import io.netty.util.concurrent.DefaultThreadFactory; import org.apache.hadoop.hbase.classification.InterfaceAudience; import org.apache.hadoop.hbase.util.Pair; @@ -32,6 +33,8 @@ import org.apache.hadoop.hbase.util.Pair; class DefaultNettyEventLoopConfig { public static final Pair<EventLoopGroup, Class<? extends Channel>> GROUP_AND_CHANNEL_CLASS = Pair - .<EventLoopGroup, Class<? extends Channel>> newPair(new NioEventLoopGroup(), + .<EventLoopGroup, Class<? extends Channel>> newPair( + new NioEventLoopGroup(0, + new DefaultThreadFactory("Default-IPC-NioEventLoopGroup", true, Thread.MAX_PRIORITY)), NioSocketChannel.class); } http://git-wip-us.apache.org/repos/asf/hbase/blob/0860bdb6/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcClient.java ---------------------------------------------------------------------- diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcClient.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcClient.java index 8c568af..cde453f 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcClient.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcClient.java @@ -21,6 +21,7 @@ import io.netty.channel.Channel; import io.netty.channel.EventLoopGroup; import io.netty.channel.nio.NioEventLoopGroup; import io.netty.channel.socket.nio.NioSocketChannel; +import io.netty.util.concurrent.DefaultThreadFactory; import java.io.IOException; import java.net.SocketAddress; @@ -51,7 +52,8 @@ public class NettyRpcClient extends AbstractRpcClient<NettyRpcConnection> { .getEventLoopConfig(conf); if (groupAndChannelClass == null) { // Use our own EventLoopGroup. - this.group = new NioEventLoopGroup(); + this.group = new NioEventLoopGroup(0, + new DefaultThreadFactory("IPC-NioEventLoopGroup", true, Thread.MAX_PRIORITY)); this.channelClass = NioSocketChannel.class; this.shutdownGroupWhenClose = true; } else {
