From 78b4f83f6bb98c8c7314d5a9f7083cb6e3f91783 Mon Sep 17 00:00:00 2001 From: zhangduo Date: Mon, 12 Sep 2016 16:32:03 +0800 Subject: [PATCH] HBASE-16614 Use daemon thread for netty event loop --- .../org/apache/hadoop/hbase/ipc/DefaultNettyEventLoopConfig.java | 5 ++++- .../src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcClient.java | 4 +++- 2 files changed, 7 insertions(+), 2 deletions(-) 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> GROUP_AND_CHANNEL_CLASS = Pair - .> newPair(new NioEventLoopGroup(), + .> newPair( + new NioEventLoopGroup(0, + new DefaultThreadFactory("Default-IPC-NioEventLoopGroup", true, Thread.MAX_PRIORITY)), NioSocketChannel.class); } 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 { .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 { -- 2.7.4